| | |
| | | this.m_ServerSocket.setSoTimeout(600000); //600 seconds
|
| | |
|
| | | Socket tmp_socket = this.m_ServerSocket.accept();
|
| | | FBS9600S_SocketClient_Thread thread = new FBS9600S_SocketClient_Thread(this.m_ConnPool,m_Data,tmp_socket);
|
| | | //FBS9600S_SocketClient_Thread thread = new FBS9600S_SocketClient_Thread(this.m_ConnPool,m_Data,tmp_socket); |
| | | FBS9600S_SocketClient_Thread_New thread = new FBS9600S_SocketClient_Thread_New(this.m_ConnPool,m_Data,tmp_socket); |
| | | thread.start();
|
| | | /*
|
| | | try {
|
| | |
| | | byte[] cipher_tx_t = null;
|
| | | cipher_tx_t = makeCommBuf(m_CMD, bf, false);
|
| | |
|
| | | //System.err.println("发送数据:"+ComFn.bytesToHexString(cipher_tx_t, cipher_tx_t.length));
|
| | | System.err.println("发送数据:"+ComFn.bytesToHexString(cipher_tx_t, cipher_tx_t.length)); |
| | | //=====================================================================//
|
| | | Date d1 = new Date();
|
| | | int rx_read_time_out = 0;
|
| | |
| | | byte[] cipher_buf = new byte[bytebuffer_for_socket_RX.limit()];
|
| | | byte[] plain_buf = new byte[bytebuffer_for_socket_RX.limit()];
|
| | | bytebuffer_for_socket_RX.get(plain_buf);
|
| | | //System.out.println("接收数据:"+ComFn.bytesToHexString(plain_buf, plain_buf.length));
|
| | | System.out.println("接收数据:"+ComFn.bytesToHexString(plain_buf, plain_buf.length)); |
| | |
|
| | | if((cipher_buf.length >= 7) && (true == getDataFromCommBuf(plain_buf,m_CMD))) {
|
| | |
|