zromq/jzmq push/pullモードとjavaコード
参照画像:http://iyuan.iteye.com/blog/974040
モデルの説明: 1.上流（タスクリリース） 2.労働者（中間、具体的な仕事） 3.下流（信号収集または作業結果収集）
上のコード:
プッシュ:
モデルの説明: 1.上流（タスクリリース） 2.労働者（中間、具体的な仕事） 3.下流（信号収集または作業結果収集）
上のコード:
プッシュ:
package com.zeromq.test.push_pull;
import org.zeromq.ZMQ;
/**
* @author larry
* @email [email protected]
* @version 2012-6-5 11:30:46
*/
public class push_demo {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket sync = context.socket(ZMQ.PUSH);
sync.connect("tcp://localhost:5564");
sync.send("".getBytes(), 0);
int update_nbr;
for (update_nbr = 0; update_nbr < 10; update_nbr++) {
sync.send("Rhubarb".getBytes(), ZMQ.NOBLOCK);
}
sync.send("END".getBytes(), 0);
}
}
/**
*
*/
package com.zeromq.test.push_pull;
import org.zeromq.ZMQ;
/**
* @author larry
* @email [email protected]
* @version 2012-6-5 11:37:46
*/
public class pull_demo {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket sync = context.socket(ZMQ.PULL);
sync.bind("tcp://*:5564");
sync.recv(0);
int update_nbr = 0;
while (true) {
byte[] stringValue = sync.recv(0);
String string = new String(stringValue);
if (string.equals("END")) {
break;
}
update_nbr++;
System.out.println("Received " + update_nbr + " updates. :" + string);
}
sync.close();
context.term();
}
}