1

我正在尝试使用一个不起作用的简单应用程序对 Jeromq 库进行测试。

这是服务器：

导入 org.zeromq.ZMQ；

public class Server  {

     public static void main(String[] args) throws Exception {

            ZMQ.Context ctx = ZMQ.context(1);

            ZMQ.Socket socket = ctx.socket(ZMQ.REP);
            socket.bind("tcp://192.168.56.1:5570");
            System.out.println("Started");

            while (!Thread.currentThread().isInterrupted()) {

                byte[] request = socket.recv(0);
                String string = new String(request);
                System.out.println("Received request: ["+string+"].");

                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                socket.send("We got message".getBytes(), 0);
            }

            System.out.println("finished");
            socket.close();
            ctx.term();           
     } 
}

因此，启动它后，我有一个日志-“已启动”。192.168.56.1 是我的本地 IP 地址，而 netstat -na（我在 Windows 上工作）显示 192.168.56.1:5570 正在监听。所以，我想没关系。我在 Windows 中打开了这个套接字。

然后在android上我写了这个：

连接建立接口：

public interface ConnectionReadyListnener {

        void onServerConnectionEstablished();

}

然后 Connection AsyckTask 建立与服务器的连接：

public class Connection extends AsyncTask<Void, Void, Void> {

    public ConnectionReadyListnener listener=null;
    public static ZMQ.Context context;
    public static ZMQ.Socket socket;


    @Override
    protected Void doInBackground(Void... params) {

        context = ZMQ.context(1);
        socket = context.socket(ZMQ.DEALER);
        socket.setIdentity("12345".getBytes(ZMQ.CHARSET));
        socket.connect("tcp://192.168.56.1:5570"); 

        return null;
    }

    @Override
    protected void onPostExecute(Void result) {
        super.onPostExecute(result);
        listener.onServerConnectionEstablished();
    }

}

和 MainActivity 在建立连接时启动测试任务：

public class MainActivity extends Activity implements ConnectionReadyListnener{
    Connection connection;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        connection = new Connection();
        connection.listener=this;
        connection.execute();
    }

    @Override
    public void onServerConnectionEstablished() {
        Toast.makeText(getApplicationContext(), "connected", Toast.LENGTH_SHORT).show();
        new TestAsynk().execute();

    }


}

这是 TestAsynk 类，用于发送服务器应接收的测试消息并将日志记录到控制台：

public class TestAsynk extends AsyncTask<Void, Void, Void>{

    @Override
    protected Void doInBackground(Void... params) {
        Connection.socket.send("Test".getBytes(), 0);
        return null;
    }

}

但它永远不会记录结果——它没有收到它。问题是我不知道为什么 - 电话（真实设备）和带有服务器的计算机在一个 WiFi 网络中。而且我还了解到 ZeroMQ 无法确定连接是否真的建立。

请帮我弄清楚。

4

1 回答 1

0

这里有很多问题。

1) 永远不要在线程之间传递套接字。ZeroMQ 中唯一的线程安全对象是 Context。在线程之间传递套接字几乎肯定是这里问题的根源。

2）如果您在服务器端遇到问题，则可能是IP地址不正确。如果可能的话，我不建议在绑定的一侧对 IP 地址进行硬编码。只需使用通配符“*”代替。所以在服务器端，它看起来像 

    socket.bind("tcp://*:5570");

onPostExecute3）你的异步模式有一个明显的错误......如果在监听器设置为活动之前运行会发生什么？至少，向您的 AsyncTask 添加一个构造函数，该构造函数接受 Activity ......类似于

public Connection(Activity listener){
    this.listener = listener;
}

4) 检查权限。过去，我需要 INTERNET 和 ACCESS_WIFI_STATE 权限。

于 2017-01-30T06:46:47.963 回答