如何正确处理tcp输入流-Java /Android

Question

我正在创建一个android应用程序，它需要一个到服务器的永久TCP连接。

我创建了一个服务，用于建立连接并侦听Inputstream上的传入字节（该服务在后台运行）。

public  class TCPServiceConnection extends Service{
        //variables......
        //...............
        public void onCreate() { 
               establishTCPConnection(): 
        }

前4个传入字节表示完整消息的消息长度。

在将完整的消息从Inputstream读入单独的缓冲区后，我想在分析消息的单独线程中调用另一个服务/异步任务。（服务应继续侦听更多传入消息）。

        public handleTCPInput() {
               while(tcp_socket.isConnected()) {
               byte[] buffer = readCompletemessagefromTCPInputstream; 
               calltoAnotherThreadToanalyzeReceivedMessage(buffer); 
               }
               //handle exceptions.......
        }

Android/Java中是否有一个现有的Messagequeue系统已经处理了对我的分离字节[]缓冲区的多重访问？

Answer 1

为了实现这一点，我建议您启动一个处理程序线程，它将不断地从输入流中读取。

一旦读取了传入消息，它就会使用处理程序将其传递给主线程。

例如，handler。sendMessage（）

现在，由于此处理不是一个繁重的操作，您可以决定主/UI线程来处理此信息，也可以启动异步任务来处理此信息。