概念：Broker：接收和分发消息的应用，RabbitMQServer就是MessageBrokerConnection：publisher/consumer和broker之间的TCP连接Channel：如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TCPConnection的开销将是巨大的，效率也较低。Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的channel进行通讯，AMQPmethod包含了channelid帮助客户端和messagebroker识别channel，所以channel之
概念：Broker：接收和分发消息的应用，RabbitMQServer就是MessageBrokerConnection：publisher/consumer和broker之间的TCP连接Channel：如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TCPConnection的开销将是巨大的，效率也较低。Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的channel进行通讯，AMQPmethod包含了channelid帮助客户端和messagebroker识别channel，所以channel之
支持.NetCore(2.0及以上)/.NetFramework(4.5及以上)，可以部署在Docker,Windows,Linux,Mac。RabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具，RabbitMQ支持的语言更多、功能更完善。 本文提供一种市面上最/极简单的使用RabbitMQ的方式，只需要会调用以下三个方法，你就几乎可以掌握整个RabbitMQ的使用：（1）SendMessage，发送一个消息（2）GetMessage，获取一个消息（3）UseMessage，使用一个消息（连续使用） 为了调用以上三个方法，首先需要从NuGet引用DeveloperSha
支持.NetCore(2.0及以上)/.NetFramework(4.5及以上)，可以部署在Docker,Windows,Linux,Mac。RabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具，RabbitMQ支持的语言更多、功能更完善。 本文提供一种市面上最/极简单的使用RabbitMQ的方式，只需要会调用以下三个方法，你就几乎可以掌握整个RabbitMQ的使用：（1）SendMessage，发送一个消息（2）GetMessage，获取一个消息（3）UseMessage，使用一个消息（连续使用） 为了调用以上三个方法，首先需要从NuGet引用DeveloperSha
1RocketMQ使用相关问题1.1保证消息的可用性/可靠性/不丢失消息可能在哪些阶段丢失呢？可能会在这三个阶段发生丢失：生产阶段、存储阶段、消费阶段所以要从这三个阶段考虑：image.png1.1.1生产在生产阶段，主要通过请求确认机制，来保证消息的可靠传递。同步发送的时候，要注意处理响应结果和异常。如果返回响应OK，表示消息成功发送到了Broker，如果响应失败，或者发生其它异常，都应该重试。异步发送的时候，应该在回调方法里检查，如果发送失败或者异常，都应该进行重试。如果发生超时的情况，也可以通过查询日志的API，来检查是否在Broker存储成功。1.1.2存储存储阶段，可以通过配置可靠性
1RocketMQ使用相关问题1.1保证消息的可用性/可靠性/不丢失消息可能在哪些阶段丢失呢？可能会在这三个阶段发生丢失：生产阶段、存储阶段、消费阶段所以要从这三个阶段考虑：image.png1.1.1生产在生产阶段，主要通过请求确认机制，来保证消息的可靠传递。同步发送的时候，要注意处理响应结果和异常。如果返回响应OK，表示消息成功发送到了Broker，如果响应失败，或者发生其它异常，都应该重试。异步发送的时候，应该在回调方法里检查，如果发送失败或者异常，都应该进行重试。如果发生超时的情况，也可以通过查询日志的API，来检查是否在Broker存储成功。1.1.2存储存储阶段，可以通过配置可靠性
前言最近在做一个可以根据用户选择的时间，实现微信推送订阅消息的功能，突然想到rabbitmq好像可以实现这个功能，本着试试的心态开始研究，第一个想到的就是使用死信队列死信队列何为死信队列，其实rabbitmq本身并不能实现延迟发送消息的功能，不过因为本身有着队列ttl+死信exchange的机制，可以借助这个机制实现延迟发送消息原理就是，用户发送消息到一个队列上并设置过期时间，但是这个队列没有消费者，到了过期时间，就由该队列绑定的死信exchange根据路由key的方式发送到另一个队列上，并消费，从而实现延迟发送注：消息不仅只有超时才会成为死信，还有可能消息被消费者reject或者返回nack
前言最近在做一个可以根据用户选择的时间，实现微信推送订阅消息的功能，突然想到rabbitmq好像可以实现这个功能，本着试试的心态开始研究，第一个想到的就是使用死信队列死信队列何为死信队列，其实rabbitmq本身并不能实现延迟发送消息的功能，不过因为本身有着队列ttl+死信exchange的机制，可以借助这个机制实现延迟发送消息原理就是，用户发送消息到一个队列上并设置过期时间，但是这个队列没有消费者，到了过期时间，就由该队列绑定的死信exchange根据路由key的方式发送到另一个队列上，并消费，从而实现延迟发送注：消息不仅只有超时才会成为死信，还有可能消息被消费者reject或者返回nack
