今天在安装zeromq的时候费了好大的力气才算装好
下面来回顾一下在linux安装zeromq的过程
首先
http://download.zeromq.org/
1.下载最新版的zeromq
http://download.zeromq.org/zeromq-3.1.0-beta.tar.gz
2 解压
tar -xvf zeromq-3.1.0-beta.tar.gz
3 运行configure
./configure --prefix=/data/zeromq (prefix 指定安装目录)
4. make
5. make install
6. 设置环境变量
export CPPFLAGS=-I/home/mine/0mq/include/
export LDFLAGS=-L/home/mine/0mq/lib/
7.测试代码
server.c
#######################################
#include </data/zeromq/include/zmq.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
int main (void)
{
void *context = zmq_init (1);
// Socket to talk to clients
void *responder = zmq_socket (context, ZMQ_REP);
zmq_bind (responder, "tcp://192.168.0.185:5555");
printf("binding on port 5555.\nwaiting client send message...\n");
while (1) {
// Wait for next request from client
zmq_msg_t request;
zmq_msg_init (&request);
char buf[32];
zmq_recv (responder,buf, &request, 0);
int size = zmq_msg_size (&request);
char *string = malloc (size + 1);
memset(string,0,size+1);
memcpy (string, zmq_msg_data (&request), size);
printf ("Received Hello string=[%s]\n",string);
free(string);
zmq_msg_close (&request);
// Do some 'work'
sleep (1);
// Send reply back to client
zmq_msg_t reply;
char res[128]={0};
snprintf(res,127,"reply:%d",random());
zmq_msg_init_size (&reply, strlen(res));
memcpy (zmq_msg_data (&reply), res, strlen(res));
char buf2[32];
zmq_send (responder, buf2, &reply, 0);
zmq_msg_close (&reply);
}
// We never get here but if we did, this would be how we end
zmq_close (responder);
zmq_term (context);
return 0;
}
########################################################
#client.c
#include <zmq.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
int main ()
{
void *context = zmq_init (1); // Socket to talk to server
printf ("Connecting to hello world server...\n");
void *requester = zmq_socket (context, ZMQ_REQ);
zmq_connect (requester, "tcp://192.168.0.185:5555");
int request_nbr;
for (request_nbr = 0; request_nbr != 10; request_nbr++)
{
zmq_msg_t request;
zmq_msg_init_data (&request, "Hello", 6, NULL, NULL);
printf ("Sending request %d...\n", request_nbr);
zmq_send (requester, &request, 0,0);
printf("send over") ;
zmq_msg_close (&request);
zmq_msg_t reply;
zmq_msg_init (&reply);
zmq_recv (requester, &reply, 0,0);
printf ("Received reply %d: [%s]\n", request_nbr, (char *) zmq_msg_data (&reply));
zmq_msg_close (&reply);
}
zmq_close (requester);
zmq_term (context);
return 0;
}
gcc server.c -o server -lzmq -L/data/zeromq/lib -I/data/zeromq/include
gcc client.c -o client -lzmq -L/data/zeromq/lib -I/data/zeromq/include
./server
./client
jzmq 是zeromq 的java客户端
下载地址
https://github.com/zeromq/jzmq/downloads
1. tar xzf zeromq-jzmq-semver-90-g58c6108.tar.gz
2. ./configure
这个时候需要上面环境变量的配置,
还需要
随便
vi /data/zeromq/.bashrc
export PATH=$PATH:/data/zeromq/include
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/data/zeromq/lib:/data/zeromq/include
只要configure 执行完毕就会生成makefile文件
3.make
4.make install
测试
hwserver.java
//
// Hello World server in Java
// Binds REP socket to tcp://*:5555
// Expects "Hello" from client, replies with "World"
//
// Naveen Chawla <naveen.chwl@gmail.com>
//
import org.zeromq.ZMQ;
public class hwserver {
public static void main(String[] args) {
// Prepare our context and socket
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.REP);
socket.bind ("tcp://*:5555");
while (true) {
byte[] request;
// Wait for next request from client
// We will wait for a 0-terminated string (C string) from the client,
// so that this server also works with The Guide's C and C++ "Hello World" clients
request = socket.recv (0);
// In order to display the 0-terminated string as a String,
// we omit the last byte from request
System.out.println ("Received request: [" +
new String(request,0,request.length-1) // Creates a String from request, minus the last byte
+ "]");
// Do some 'work'
try {
Thread.sleep (1000);
}
catch(InterruptedException e){
e.printStackTrace();
}
// Send reply back to client
// We will send a 0-terminated string (C string) back to the client,
// so that this server also works with The Guide's C and C++ "Hello World" clients
String replyString = "World" + " ";
byte[] reply = replyString.getBytes();
reply[reply.length-1]=0; //Sets the last byte of the reply to 0
socket.send(reply, 0);
}
}
}
hwclient.java
//
// Hello World client in Java
// Connects REQ socket to tcp://localhost:5555
// Sends "Hello" to server, expects "World" back
//
// Naveen Chawla <naveen.chwl@gmail.com>
//
import org.zeromq.ZMQ;
public class hwclient{
public static void main(String[] args){
// Prepare our context and socket
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.REQ);
System.out.println("Connecting to hello world server...");
socket.connect ("tcp://localhost:5555");
// Do 10 requests, waiting each time for a response
for(int request_nbr = 0; request_nbr != 10; request_nbr++) {
// Create a "Hello" message.
// Ensure that the last byte of our "Hello" message is 0 because
// our "Hello World" server is expecting a 0-terminated string:
String requestString = "Hello" + " ";
byte[] request = requestString.getBytes();
request[request.length-1]=0; //Sets the last byte to 0
// Send the message
System.out.println("Sending request " + request_nbr + "...");
socket.send(request, 0);
// Get the reply.
byte[] reply = socket.recv(0);
// When displaying reply as a String, omit the last byte because
// our "Hello World" server has sent us a 0-terminated string:
System.out.println("Received reply " + request_nbr + ": [" + new String(reply,0,reply.length-1) + "]");
}
}
}
javac -classpath /data/jzmq/share/java/zmq.jar -d . h*.java
java -Djava.library.path=/data/jzmq/lib -cp /data/jzmq/share/java/zmq.jar:. hwserver
java -Djava.library.path=/data/jzmq/lib -cp /data/jzmq/share/java/zmq.jar:. hwclient
显示内容:
server端
Received request: [Hello]
Received request: [Hello]
Received request: [Hello]
Received request: [Hello]
Received request: [Hello]
Received request: [Hello]
client端
Connecting to hello world server...
Sending request 0...
Received reply 0: [World]
Sending request 1...
Received reply 1: [World]
Sending request 2...
Received reply 2: [World]
Sending request 3...
Received reply 3: [World]
Sending request 4...
Received reply 4: [World]
Sending request 5...
分享到:
相关推荐
zeromq安装编译 里面有详细说明以及测试代码,非常好用。
消息队列zeromq学习的安装包之一libsodium,为学习zeromq安装部署的同学们提供帮助,zeromq是消息队列中的一种技术,安装过程中要注意版本对应。
“ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层,像框架一样的一个socket library,他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库,可在多个线程、内核和主机盒之间弹性伸缩。ZMQ的明确目标是...
ZeroMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层,像框架一样的一个socket library,他使得Socket编程更加简单、简洁和性能更高。(摘自百度百科) ZMQ官方网址http://zeromq.org/ ZMQ本身只提供了C++版本的下载,...
文字结合截图,详细描述使用ZeroMQ和jzmq的安装配置过程.
zeromq-4.3.2.tar.gz,可在linux下编译安装,能够使用zeromq进行sorket开发,多线程,提升性能,效率,可以配合msgpack进行使用,是个好的扩展插件
消息队列zeromq的c语言安装包czmq-4.2.1版本,为学习安装部署zeromq的同学提供c语言版本的安装包,要注意跟zeromq的版本对应,否则后期会报错。
“ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层,像框架一样的一个socket library,他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库,可在多个线程、内核和主机盒之间弹性伸缩。ZMQ的明确目标是...
在Win10上使用MingW的编译套件gcc7.3.0编译的32位ZeroMQ4.3.4的库(当前最新版)。
在 linux redhat 上安装zeromq 和 jzmq
zeromq-2.1.7.tar.gz 的早期的一个版本,本人已安装成功 放心使用
消息队列zeromq的go语言测试实例包,为学习安装部署zeromq的同学提供,注意该安装包中的测试实例为go语言版本,要根据各位安装的zeromq版本下载。
Centos6安装zeromq4.0.4 并且附有服务端和客户端测试程序
zeromq中的zmq.hpp头文件,用于编写zeromq代码
在CentOS7操作系统下编译的最新版zeromq 4.3.1静态库和动态库,经过测试程序的检验,库可用
zeromq-4.2.3.tar.gz 一个稳定的版本,可以安装使用!
此类将安装zeromq库和头文件包(如果它们是单独打包的)。 # defaults class { 'zeromq' : version => 3 } 参数 version String默认为: 3 控制安装主要API version的zeromq软件包集。 目前,只
需要先安装 ZeroMQ(见下文) 要构建,请运行“make” 要测试,如果可以从命令行调用 MATLAB,请运行“make test”。 在 Ubuntu 12.04 上安装 ZeroMQ 3.2.2 从下载 tarball 在解压存档的根目录中,运行以下命令...
安装ZeroMQ(用于Libbitcoin),例如在macOS上: brew install zeromq 安装Postgres,例如在macOS上: brew install postgresql 例如在macOS上安装Redis: brew install redis并查看。 要使用Rails缓存,请安装...