android - socket有数据可读时android有回调机制吗

Question

好吧，我熟悉 C 和 iOS 环境中的套接字编程。但是现在尝试通过套接字连接我的 android 和我的远程服务器......作为开始，我用 C 编写了一个简单的服务器程序并在我的桌面耐心地等待连接请求，接受连接，然后等待一些请求字符串，并在获取请求字符串时返回一些响应字符串，然后再次等待下一个请求并继续..你明白了..

到目前为止

1. 我已经与我的 android 和服务器建立了连接
2. 发送和接收数据

这是我的客户端代码..

public class SocketMaster {
    private Socket clientSocket     =   null;
        BufferedReader socketReadStream =   null;
    public boolean connectToHost(String ip, int port){
        try {
            InetAddress serverAddr  =   InetAddress.getByName(ip);
            try {
                clientSocket        =   new Socket(serverAddr, port);
                socketReadStream    =   new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                String line     =   null;
                String stringToSend =   "This is from client ...Are you there???";

                //Write to server..stringToSend is the request string..
                this.writeToServer(stringToSend);

                //Now read the response..
                while((line = socketReadStream.readLine()) != null){
                    Log.d("Message", line);
                }
            } catch (IOException e) {
                e.printStackTrace();
                return false;
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

    public boolean writeToServer(String stringToSend){
        DataOutputStream dos        =   null;
        try {
            dos                         =   new DataOutputStream(clientSocket.getOutputStream());
        } catch (IOException e) {
            e.printStackTrace();
            return false;
        }
        try {
            dos.write(stringToSend.getBytes());
        } catch (IOException e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }
}

我从另一个 Activity 创建一个 SocketMaster 对象并调用 connectToHost 传递服务器的 ip 和端口..一切正常，我能够连接、发送和接收数据..

现在我的问题是关于这些行

//Now read the response..
while((line = socketReadStream.readLine()) != null){
     Log.d("Message", line);
}

据我了解，执行这段代码的线程

• 阻塞直到有数据可读
• 如果数据可用，读取它，然后因为循环再次阻塞直到下一个数据 block 到达

只是我不能在主线程上运行这段代码，因为它会阻塞我的 UI Activity 。我可以考虑在后台线程中运行它，这是一个选项......

但理想情况下我想要的是...

回调(我认为，android 术语中的监听器，任何熟悉 iOS CFSocket 和 callback 的人)，方法，当有数据可供读取时调用，这样我可以只读取数据然后返回..

在 android/java 中是否有任何这样的机制...如果没有(:-()，任何人都可以将我链接到一些在后台完成套接字处理的示例...

编辑:我不是在问自己创建一个回调机制。我只是在问是否有任何监听器存在，当有数据要读取时，当连接断开连接时通知你。因此我可以消除上面给出的 while 循环......如果没有任何回调，我准备将此套接字移动到另一个线程，该线程循环并读取数据(实际上我已经完成了)...

**

再次编辑赏金时间..

**

好吧，我是 2 位软弱的老 android/java 开发人员，拥有 3.5 年的 c/c++/objective c 开发经验……所以我看到了低级别的 c native 套接字(使用 read 时会阻塞(可配置) () 和 recv()) 和 apple 的 CFSocket(它本身是 C 套接字，但提供了一个包装器来提供回调机制)。如果没有现成的替代方案，我会全心全意地准备去做，但为什么要重新发明轮子呢？)...我开始将 Java 理解为非常先进和高级的平台。我认为应该有一些更高级别的包装器库潜伏在周围..所以我正在考虑通过开始赏金来增加这个线程的观众..

Answer 1

在 Java 中没有现成的回调。您可以使用 NIO 包中的类轻松实现一个。您主要需要 Selector 和 SocketChannel。如果您熟悉 select(2)，应该很容易理解。如果没有，请尝试 NIO 教程。

http://download.oracle.com/javase/1.5.0/docs/api/java/nio/channels/SocketChannel.htmlhttp://download.oracle.com/javase/1.5.0/docs/api/java/nio/channels/Selector.html

在任何情况下，您都必须轮询套接字以检查是否有数据，而您不能在主线程上执行此操作。除非你的 Android 应用程序应该在同一个线程上管理多个连接，否则使用阻塞 IO 可能会容易得多。另一件需要考虑的事情:如果这必须连续/长时间运行，您需要将其移至服务。即使那样，如果资源耗尽，操作系统也可以终止它，因此请准备好处理重新连接。

HTH