ZMQ.Socket JAVA 代码示例

关于ZMQ的Socket编程，网上有一些例子，但都是Python语言的，而JAVA语言的例子少之又少，这里以JAVA为例，简单介绍一下。

转载请注明出处：http://blog.csdn.net/cdmamata/article/details/8593158

ZMQ 通讯模式有三种：

1、请求回应模式

2、发布订阅模式

3、管道模式

关于这三种模式各自的特点，这里不做详细介绍，

附传送门：http://wenku.baidu.com/view/27ee898ea0116c175f0e4832.html

ZMQ.Socket 简单示例代码

ZmqSocketServer.java

package storm.test;

import java.util.Date;
import org.zeromq.ZMQ;

/**
* ZMQ Socket 服务端
* @author Administrator
*
*/

public class ZmqSocketServer {

public static void main(String[] args) {

ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.PUB);	//ZMQ.PUB 指定通讯模式为 【发布订阅模式】的 发布者
socket.bind ("tcp://192.168.1.100:9005");	//绑定服务地址及端口

while (true) {
String time = new Date().getTime() + "";

byte[] reply = time.getBytes();

socket.send(reply, 0);
System.out.println("@@@@ Server Send:" + time);
try {
Thread.sleep (3000);
}catch(InterruptedException e){
e.printStackTrace();
}
}
}
}

ZmqSocketClient.java

package storm.test;

import org.zeromq.ZMQ;

/**
* ZMQ socket 客户端
* @author Administrator
*
*/
public class ZmqSocketClient {
public static void main(String args[]) {

ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.SUB);	//ZMQ.SUB 指定该Socket 为接收，设置的不对，会接收不到数据

byte[] filter = "".getBytes();
socket.subscribe(filter);	//必须设置filter,否则接收不到任何数据，这里将空数据过滤掉

socket.connect("tcp://192.168.1.100:9005");	//创建链接

while (true) {
byte[] msg = null;
try {
msg = socket.recv(0);
String time = new String(msg);
System.out.println("#### Client Receive:" + time);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}

当然，还需要

jzmq-2.1.0.jar