NetMQ——推拉模式 Push-Pull

摘要:
使用(varpushSocket=newPushSocket(“@tcp://127.0.0.1:1212“)){while(true){//pushSocket.Connect();stringstr=Console.ReadLine();pushSock.SendFrame(str);}}使用(varreceiver=newPullSocket(”˃tcp://12

推送端

 using (var pushSocket = new PushSocket("@tcp://127.0.0.1:1212"))
            {
                while (true)
                {
                    //pushSocket.Connect();
                    string str =Console.ReadLine();
                    pushSocket.SendFrame(str);
                }
            
                         
            }

拉取端

 using (var receiver = new PullSocket(">tcp://127.0.0.1:1212"))
            //using (var sender = new PushSocket(">tcp://localhost:5558"))
{
                //receiver.
                //process tasks forever
                while (true)
                {
                  
                    string workload =receiver.ReceiveFrameString();
                   
                    Console.WriteLine(workload);
                
                }
            }

免责声明:文章转载自《NetMQ——推拉模式 Push-Pull》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇第1周:指针与字符串MyBatis基础总结下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

jenkins初始化和安装插件

1.find / -name 'default.json' 2. sed -i 's/http://updates.jenkins-ci.org/download/https://mirrors.tuna.tsinghua.edu.cn/jenkins/g' /var/lib/jenkins/updates/default.json &&...

javascript 未来新方法的介绍

JavaScript1.6数组方法的扩展 var tmp = [1, 2, 3, 4, 5, 3]; console.log('indexOf:找出数组中某一对象的下标,如果没有则为-1'); console.log(tmp.indexOf(3) == 2); console.log(tmp....

Ambari2.7.4+HDP3.1.4在centos7.6部署

一.下载安装包 使用在线安装特别慢,所有的安装包加起来有9个G左右,所以需要先下载相关安装包到服务器,通过配置本地源的方式来实现的离线安装。 在私有集群中部署时,客户机房的网络情况不可预测,因此也需要使用离线部署的方式。 根据官方文档 https://docs.cloudera.com/HDPDocuments/Ambari-2.7.4.0/bk_am...

Nodejs mysql 数据库增、删、改、查 操作

Nodejs mysql的增、删、改、查操作 Nodejs连接mysql的增、删、改、查操作(转载 自:http://blog.sina.com.cn/s/blog_5a6efa330102vctw.html) 一、准备 nodejs的教程,大多以操作mongodb为示例。但是mongodb有一些局限性,具体官网上有说。我打算用MySQL,因为多少还有...

三种比较好玩的黑客效果JS代码(摘取)

<html> <head> <title>The Matrix</title> <script src="http://ajax.googleapis.com/ajax/libs/jquery/1.7.1/jquery.min.js" type="text/ja...

三维地图的加载以及基本功能的开发

注意属性气泡功能一定要设置图层可选中: //优化S3M模型加载 layers.forEach(function(ele){ //设置图层为可选中状态 ele.selectEnabled = true; ele.clearMemoryImmediately=...