0

嘿社区我有以下 ServerSocket 应该侦听端口 53000 并记录任何接收到的数据。但是，我似乎无法通过 server.accept() 阻塞调用。

public void run() {

        SocketServer server = new ServerSocket(53000);


        //---buffer store for the stream---
        byte[] buffer = new byte[1024];
        //---bytes returned from read()---
        int bytes;

        //---keep listening to the InputStream until an
        // exception occurs---
        while (true) {
            try {

                socket = server.accept();
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

                String str = in.readLine();

                Log.i("received response from server", str);

                in.close();
                socket.close();

            } catch (IOException e) {
                Log.e(TAG, e.getMessage());
            } catch (Exception e){
                server.close();
                Log.e(TAG, e.getMessage());
            }
        }

    }

我还在 Manifest 文件中为应用程序授予了 INTERNET 权限。()

为了增加谜团，我还验证了客户端响应已发送到该端口。

我需要做些什么来完成这项工作吗？

谢谢。

4

2 回答 2

10

您的代码非常混乱，甚至无法编译。我做了一些调整，以便我可以测试你的代码，它工作正常。这是我使用的测试应用程序：

package com.test.stackoverflow

import java.io.BufferedReader;

public class ServerSocketTestActivity extends Activity {
    /** Called when the activity is first created. */
    private static String TAG = "ServerSocketTest";

    private ServerSocket server;

    Runnable conn = new Runnable() {
        public void run() {
            try {
                server = new ServerSocket(53000);

                while (true) {
                    Socket socket = server.accept();
                    BufferedReader in = new BufferedReader(
                            new InputStreamReader(socket.getInputStream()));

                    String str = in.readLine();

                    Log.i("received response from server", str);

                    in.close();
                    socket.close();
                }
            } catch (IOException e) {
                Log.e(TAG, e.getMessage());
            } catch (Exception e) {             
                Log.e(TAG, e.getMessage());
            }
        }
    };

    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);

        new Thread(conn).start();
    }

    @Override
    protected void onPause() {      
        super.onPause();
        if (server != null) {
            try {
                server.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }   
}

使用此代码和通过运行的 netcat，adb shell我能够连接并与应用程序通信。

于 2012-06-19T19:22:03.610 回答
0

与客户端一起工作时声明这些方法来访问流

// gets the input stream // ObjectInputStream input; 
// gets the output stream // ObjectOutputStream output;
// ServerSocket server;
// Socket connection;

也许你有另一个类来访问套接字；

server = new ServerSocket(5001, 100);

// 第一步创建套接字连接 server = new ServerSocket(5001, 100); while(条件为真)
//第2步等待连接

// 第 3 步获取流

// 第 4 步：处理连接

// 第五步：关闭连接

于 2013-11-21T05:19:14.253 回答