動作しない単純なアプリを使用して、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 で開きました。
それからアンドロイドで私はこれを書きました:
接続を確立するためのインターフェイス:
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();
}
}
そして、サーバーが受信してコンソールに記録する必要があるテストメッセージを送信するための TestAsync クラスは次のとおりです。
public class TestAsynk extends AsyncTask<Void, Void, Void>{
@Override
protected Void doInBackground(Void... params) {
Connection.socket.send("Test".getBytes(), 0);
return null;
}
}
しかし、結果をログに記録することはありません。結果を受け取りません。問題は、理由がわからないことです-電話（実際のデバイス）とサーバーを備えたコンピューターが1つのWiFiネットワーク内にあります。また、ZeroMQ が接続が本当に確立されているかどうかを確認する方法がないことも学びました。
私がそれを理解するのを手伝ってください。