| | |
|---|
| | | public void run() {
|
|---|
| | | while (true) {
|
|---|
| | | try {
|
|---|
| | | if (!connected) {
|
|---|
| | | Thread.sleep(200);
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | | SocketRequest socketRequest = mMessageQueue.take();
|
|---|
| | | // final String sendStr = new String(socketRequest.getData(), 0, socketRequest.getData().length);
|
|---|
| | | // LogUtils.i("发送数据：" + sendStr);
|
|---|
| | | if (System.currentTimeMillis() - socketRequest.getTime() > 5000) {
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | | final String action = socketRequest.getAction();
|
|---|
| | | try {
|
|---|
| | |
|
|---|
| | | client.sendMsg(socketRequest.getData());
|
|---|
| | | if (!TextUtils.isEmpty(action)) {
|
|---|
| | | SendListener sendListener = sendMap.get(action);
|
|---|
