Android - NetworkOnMainThreadException与okhttp websocket

我有Android okhttp Websockets的线程问题。我正在做一个聊天应用程序，我需要使用websocket从我们的服务器读写。Android - NetworkOnMainThreadException与okhttp websocket

我在其他文章阅读与Okhttp，我应该使用StrictMode.ThreadPolicy.Builder（）。permitAll（），因为它有一些问题等我添加它。

但我不断收到这个错误，当我尝试的sendMessage：

W/System.err的：android.os.NetworkOnMainThreadException 09-13 17：13：32.198 22766-22766/com.microsoft.translator

请注意，我在不同的线程上发送消息，而不是在主线程上。

这是我的代码。感谢任何帮助。

创建的WebSocket：

@Override 
protected void onCreate(Bundle savedInstanceState) { 
    super.onCreate(savedInstanceState); 
    setContentView(R.layout.activity_my_chat); 

    StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder().permitAll().build(); 
    StrictMode.setThreadPolicy(policy); 

    // lot other init stuff 
    createWebSocket(); 
} 

private void createWebSocket() { 
    okHttpClient = new OkHttpClient(); 
    Request request = new Request.Builder() 
      .url(WSS_URL + token) 
      .build(); 
    webSocketCall = WebSocketCall.create(okHttpClient, request); 
    webSocketCall.enqueue(this); 
} 

@Override 
public void onOpen(WebSocket webSocket, Response response) { 
    try { 
     Log.d(TAG, "onOpen: " + response.message()); 
     String message = createJsonMessage("Hello"); 
     byte[] messageBytes = message.getBytes(); 
     showToastOnUIThread("OnOpen sending message"); 

     webSocket.sendMessage(WebSocket.PayloadType.TEXT, new Buffer().write(messageBytes)); 
     this.webSocket = webSocket; 
     //startRepeatingTask(); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

    private void sendMessage(final String msgString) { 

    Runnable postMessageThread = new Runnable() { 
     @Override 
     public void run() { 
      String message = createJsonMessage(msgString); 
      byte[] messageBytes = message.getBytes(); 

      try { 
       if (webSocket != null) { 
        try { 
         webSocket.sendMessage(WebSocket.PayloadType.TEXT, new Buffer().write(messageBytes)); 
        } catch (IOException e) { 
         e.printStackTrace(); 
         Toast.makeText(ChatActivity.this, e.getMessage(), Toast.LENGTH_SHORT).show(); 
        } catch (Exception ex) { 
         ex.printStackTrace(); 
         Toast.makeText(ChatActivity.this, ex.getMessage(), Toast.LENGTH_SHORT).show(); 
        } 
       } 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } 
     } 
    }; 
    postMessageThread.run(); 
}

来源

2016-09-14 techtinkerer

'我应该使用StrictMode.ThreadPolicy.Builder（）。 permitAll（）'。不，你最好不要那样做。 – greenapps

我觉得你的代码应该是这样的：

new Thread(new Runnable() { 
     public void run() { 
      // call send message here 
     } 
    }).start();

或者你可以使用Asyntask

来源

2016-09-14 04:12:59

是不是我已经有了？ Runnable postMessageThread = new Runnable（）{ @Override public void run（）{...}你是否想说使用Thread而不是Runnable类型的变量？ – techtinkerer

我觉得你用'Runnable'编码在UI线程上运行，不会创建新线程，所以你会收到错误'NetworkOnMainThreadException'。所以新的线程将创建另一个线程。但我建议使用Asyntask来完成网络请求。 –

Android - NetworkOnMainThreadException与okhttp websocket

回答

相关问题