博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
开源消息队列:NetMQ
阅读量:5890 次
发布时间:2019-06-19

本文共 1933 字,大约阅读时间需要 6 分钟。

是  的C#移植版本。

是一个轻量级的消息内核,它是对标准socket接口的扩展。它提供了一种异步消息队列,多消息模式,消息过滤(订阅),对多种传输协议的无缝访问。

NetMQ 也是一个社区开源项目,网站在Github上 , 可以通过Nuget包获取。

Ø  是一个并发框架.

Ø  支持通过进程内(Inproc),进程间(IPC), TCP, 和多播来传递消息.
Ø  支持多对多的列表、发布/订阅、管道和接收/回复连接.
Ø  支持异步.

C# 客户端服务端

Server.cs

public static void Main (string[] args)      {            using (NetMQContext context = NetMQContext.Create())            {                Server(context);            }       }        static void Server(NetMQContext context)        {            using (NetMQSocket serverSocket = context.CreateResponseSocket())            {                serverSocket.Bind("tcp://*:5555");                while (true)                {                    string message = serverSocket.ReceiveString();                    Console.WriteLine("Receive message {0}", message);                    serverSocket.Send("World");                    if (message == "exit")                    {                        break;                    }                }            }        }
 
Client.cs
public static void Main (string[] args)        {            using (NetMQContext context = NetMQContext.Create())            {                Client(context);            }             }        static void Client(NetMQContext context)        {            using (NetMQSocket clientSocket = context.CreateRequestSocket())            {                clientSocket.Connect("tcp://127.0.0.1:5555");                while (true)                {                    Console.WriteLine("Please enter your message:");                    string message = Console.ReadLine();                    clientSocket.Send(message);                    string answer = clientSocket.ReceiveString();                    Console.WriteLine("Answer from server: {0}", answer);                    if (message == "exit")                    {                        break;                    }                }            }        }
NetMQ也支持Mono,下面是在Mono上的运行:
 

转载地址:http://uxysx.baihongyu.com/

你可能感兴趣的文章
Linux快捷键汇总
查看>>
apache配置https步骤
查看>>
Linux下文本文件中^M 符号问题的解决
查看>>
JVM性能监控诊断
查看>>
php 魔术方法 __debugInfo()
查看>>
【学习笔记】Android 图像加载类库使用
查看>>
RabbitMQ虚拟主机作用以及配置
查看>>
Log4J基础详解及示例大全
查看>>
CentOS7.2 Keepalived + Nginx 实现高可用性
查看>>
U盘中word文件误操作后恢复案例
查看>>
手机验证码
查看>>
噩梦遇地震,醒后忆岁月
查看>>
对面向对象的理解
查看>>
java反射
查看>>
iPhone开发面试题--葵花宝典
查看>>
RAC节点重启分析
查看>>
百度自动驾驶一战成名 造车新势力高调发声
查看>>
打哈欠 为什么会传染
查看>>
通过dubbo暴露接口调用方法,及基于zookeeper的dubbo涉及配置文件【转】
查看>>
MySQL的简单操作方法:PreparedStatement
查看>>