通过RabbitMQ 进行消息通知

/// <summary>/// 通过RabbitMQ 进行消息通知/// </summary>/// <param name="MQCode">消息队列的名称</param>/// <param name="MQmessage">具体消息信息</param>/// <returns></returns>public bool funSendRabbitMQ(string MQCode, string MQmessage){bool flag = true;string Remesssage = "";try{var mqFactory = new ConnectionFactory();mqFactory.HostName = MQhost;//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。if (!string.IsNullOrEmpty(MQPort)){mqFactory.Port = int.Parse(MQPort);}mqFactory.UserName = MQusername;//默认用户名,用户可以在服务端自定义创建，有相关命令行 mqFactory.Password = MQpassword;//默认密码using (var mqConnection = mqFactory.CreateConnection())//连接服务器，即正在创建终结点。 {//创建一个通道，这个就是Rabbit自己定义的规则了，如果自己写消息队列，这个就可以开脑洞设计了 //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue using (var channel = mqConnection.CreateModel()){channel.QueueDeclare(MQCode, true, false, false, null);//创建一个名称为kibaQueue的消息队列 var properties = channel.CreateBasicProperties();properties.DeliveryMode = 1;string message = MQmessage; //传递的消息内容  channel.BasicPublish("", MQCode, properties, Encoding.UTF8.GetBytes(MQmessage)); //生产消息 }}Remesssage += "通知成功！";}catch (Exception ex){flag = false;Remesssage += "通知失败！" + ex.Message;}finally{ }return flag;}

通过RabbitMQ 进行消息通知相关推荐

Redis消息通知系统的实现
Redis消息通知系统的实现 Posted on 2012-02-29 by 老王 http://huoding.com/2012/02/29/146 最近忙着用Redis实现一个消息通知系统,今天大 ...
rabbitmq 取消消息_认识RabbitMQ从这篇文章开始
关于RabbitMQ 出身:诞生于金融行业的消息队列语言:Erlang 协议:AMQP(Advanced Message Queuing Protocol 高级消息队列协议) 关键词:内存队列,高可 ...
rabbitmq 取消消息_SpringBoot整合RabbitMQ实现延迟消息
## RabbitMQ RabbitMQ是一个被广泛使用的开源消息队列.它是轻量级且易于部署的,它能支持多种消息协议.RabbitMQ可以部署在分布式和联合配置中,以满足高规模.高可用性的需求. R ...
最近发现系统rabbitmq丢消息比较严重，于是想了些方案来查找原因，给将消息发送方式添加确认机制。我们在本地模拟了wms发送打标消息的场景. 1. 有事务 2. 先发点对点队列, 再发订
最近发现系统rabbitmq丢消息比较严重,于是想了些方案来查找原因,给将消息发送方式添加确认机制. 我们在本地模拟了wms发送打标消息的场景. 1. 有事务 2. 先发点对点队列, 再发订阅队列 3 ...
第四十六章：SpringBoot RabbitMQ完成消息延迟消费
在2018-3-1日SpringBoot官方发版了2.0.0.RELEASE最新版本,新版本完全基于Spring5.0来构建,JDK最低支持也从原来的1.6也改成了1.8,不再兼容1.8以下的版本,更 ...
rabbitmq丢消息的处理方法
最近发现系统rabbitmq丢消息比较严重,于是想了些方案来查找原因,给将消息发送方式添加确认机制. 我们在本地模拟了wms发送打标消息的场景. 1. 有事务 2. 先发点对点队列, 再发订阅队列 3 ...
JAVA社交平台项目第四天消息通知系统
第4章 - 消息通知系统学习目标: 了解消息通知系统的业务场景了解消息通知和即时通讯区别实现消息通知微服务的基本功能实现文章订阅和群发消息实现文章点赞和点对点消息了解基于数据库实现的通知系 ...
springboot整合rabbitmq的发布确认，消费者手动返回ack，设置备用队列，以及面试题：rabbitmq确保消息不丢失
目录 1.生产者发消息到交换机时候的消息确认 2.交换机给队列发消息时候的消息确认 3.备用队列 3.消费者手动ack rabbitmq的发布确认方式,可以有效的保证我们的数据不丢失. 消息正常发送的 ...
消息通知系统详解2---后端设计
消息通知系统详解1-通讯方式消息通知系统详解2-后端设计消息通知系统详解3-Netty 消息通知系统详解4-整合Netty和WebSocket 目录整体设计上线登录后向系统索取在线时系统向接 ...

通过RabbitMQ 进行消息通知

通过RabbitMQ 进行消息通知

通过RabbitMQ 进行消息通知相关推荐

最新文章

热门文章