| | |
| | | connected=true;
|
| | | client.onConnectStatus(ConnectStatus.CONNECTED);
|
| | | }catch(Exception e) {
|
| | | LogUtils.e(e.getMessage());
|
| | | LogUtils.e("连接异常"+e.getMessage());
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | while (true) {
|
| | | try {
|
| | | SocketRequest socketRequest = mMessageQueue.take();
|
| | | final String sendStr = new String(socketRequest.getData(), 0, socketRequest.getData().length);
|
| | | LogUtils.i("发送数据:" + sendStr);
|
| | | // final String sendStr = new String(socketRequest.getData(), 0, socketRequest.getData().length);
|
| | | // LogUtils.i("发送数据:" + sendStr);
|
| | | final String action = socketRequest.getAction();
|
| | | try {
|
| | | client.sendMsg(socketRequest.getData());
|