.net mqtt 消息收发

1、添加引用 Apache.NMS.ActiveMQ;

2、发送代码

  /// <summary>/// 消息发送/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void button1_Click(object sender, EventArgs e){String QueuesNameESF = "itmayiedu-topic";String msg = "";Uri _uri = new Uri(String.Concat("activemq:tcp://127.0.0.1:61616"));IConnectionFactory factory = new ConnectionFactory(_uri);using (IConnection conn = factory.CreateConnection("admin", "admin")){using (ISession session = conn.CreateSession()){conn.Start();IDestination destination = SessionUtil.GetDestination(session, QueuesNameESF);using (IMessageProducer producer = session.CreateProducer(destination)){//发送消息producer.Send("itmayiedu1");}}}}

3、接收代码

 /// <summary>/// 消息发送/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btn_Receive_Click(object sender, EventArgs e){String QueuesNameESF = "itmayiedu-topic";String msg = "";Uri _uri = new Uri(String.Concat("activemq:tcp://127.0.0.1:61616"));IConnectionFactory factory = new ConnectionFactory(_uri);using (IConnection conn = factory.CreateConnection("admin", "admin")){using (ISession session = conn.CreateSession()){conn.Start();IDestination destination = SessionUtil.GetDestination(session, QueuesNameESF);using (IMessageConsumer consumer = session.CreateConsumer(destination)){ITextMessage message = consumer.Receive() as ITextMessage;Console.WriteLine("接收消息：{0}", message.Text);//msg = message.Text.ToString();}}}}

.net mqtt 消息收发相关推荐

RabbitMQ实现中AMQP与MQTT消息收发异同
实现了AMQP与MQTT(至多一次)后,用多个队列以topic exchange的方式用相同交换机监听同一个主题(topic),发现情况存在不同,觉得有点意思,所以记录了下来. 用2个MQTT(分别记 ...
java mqtt paho_使用eclipse paho在java端实现MQTT消息的收发（客户端与服务端实例）...
一.MQTT(消息队列)简介 MQTT(MQ Telemetry Transport)是IBM开发的一种网络应用层的协议,提供轻量级的,支持可发布/可订阅的的消息推送模式,使设备对设备之间的短消息通信 ...
MQTT 客户端收发 MQTT 消息
本文主要介绍如何使用 MQTT 客户端收发 MQTT 消息,并给出示例代码供前期开发测试参考,包括资源创建.环境准备.示例代码.注意事项等. 注意: 本文给出的实例均基于 Eclipse Paho J ...
微信小程序--P2P消息收发模式（MQTT）
目录前言 js demo 参数 new Paho.Client 创建对象 onConnectionLost 连接丢失回调 onMessageArrived 监听数据 disconnect() : ...
Java物联网开发(二) —— 开源百万级分布式 MQTT 消息服务器EMQX
开源百万级分布式 MQTT 消息服务器EMQX 一. 是什么 1. 简介 2. 分类 3. EMQ X 消息服务器功能列表二. 安装 1. 安装方式 rpm安装 docker安装免安装 2. 目录 ...
发布MQTT消息究竟有多快？
How fast can you publish MQTT messages? 现在许多的智能硬件应用都需要从传感器获得相应的数据,处理后把这些数据传递到后端.为了能够评估这些应用的性能,首先我们需要 ...
emqtt php页面,EMQTT(Erlang MQTT消息服务器)
EMQTT(Erlang MQTT消息服务器) Erlang MQTT消息服务器简称EMQTT. EMQTT是采用Erlang语言开发,全面支持MQTT V3.1.1协议,支持集群和大规模连接的开源M ...
第五节 RabbitMQ在C#端的应用-消息收发
原文:第五节 RabbitMQ在C#端的应用-消息收发版权声明:未经本人同意,不得转载该文章,谢谢 https://blog.csdn.net/phocus1/article/details/873 ...
在线提交信息程序 php,在线短消息收发的程序,不用数据库_php基础_脚本
在线短消息收发的程序,不用数据库_php基础_脚本发布时间:2016-06-17 来源: 点击: 次 login.php session_start(); $nickname=$name; sess ...

.net mqtt 消息收发

.net mqtt 消息收发相关推荐

最新文章

热门文章