package server;
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
public class Worker extends Thread {
private Context context;
private int workerNum;
Worker (Context context,int worker)
{
this.context = context;
this.workerNum=worker;
}
@Override
public void run() {
ZMQ.Socket socket = context.socket(ZMQ.REP);
socket.connect ("inproc://workers");
while (true) {
// Wait for next request from client (C string)
String request = socket.recvStr (0);
System.out.println ( Thread.currentThread().getName() + " Received request: [" + request + "]");
// Do some 'work'
try {
Thread.sleep (1000);
} catch (InterruptedException e) {
}
// Send reply back to client (C string)
socket.send("work"+ this.workerNum +"reply is: "+"world", 0);
}
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
com.zeromq.multithread.rar (18个子文件)
com.zeromq.multithread
pom.xml 549B
target
test-classes
classes
client
Request2.class 2KB
Request3.class 2KB
Request1.class 2KB
server
Worker.class 2KB
MainServer.class 1KB
META-INF
maven
com.zeromq
com.zeromq.multithread
pom.xml 549B
pom.properties 255B
MANIFEST.MF 108B
.settings
org.eclipse.m2e.core.prefs 90B
org.eclipse.jdt.core.prefs 243B
src
test
resources
java
main
resources
java
client
Request3.java 915B
Request1.java 915B
Request2.java 915B
server
Worker.java 985B
MainServer.java 855B
.project 574B
.classpath 1KB
共 18 条
- 1
资源评论
- 心在梦想2018-10-18已下载,准备学习中!
- __BlueCat2019-07-24资源还行,但是例子太简单, 对我没有帮助
- 爱燃4192020-06-07资源还可以,我的问题已经解决
flourishLi
- 粉丝: 6
- 资源: 17
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功