分类：rabbitMQ

2020
11-29

Rabbitmq heartbea心跳检测机制原理解析

前言使用rabbitmq的时候，当你客户端与rabbitmq服务器之间一段时间没有流量，服务器将会断开与客户端之间tcp连接。而你将在服务器上看这样的日志：missedheartbeatsfromclient,timeout:xxs这个间隔时间就是心跳间隔。heartbeat通常用来检测通信的对端是否存活（未正常关闭socket连接而异常crash）。其基本原理是检测对应的socket连接上数据的收发是否正常，如果一段时间内没有收发数据，则向对端发送一个心跳检测包，如果一段... 继续阅读 >

2020
11-17

SpringBoot中使用 RabbitMQ的教程详解

本章主要建立在已经安装好Erlang以及RabbitMQ的基础上，接下来，简单介绍一下使用一、Direct直接模式通过routingKey和exchange决定的那个唯一的queue可以接收消息1、首先到RabbitMQ的管理界面新建一个队列（Direct模式）2、测试项目的基础结构如下：这里为了方便测试，直接在父项目中建立两个子模块（生产者和消费者）3、pom.xml文件的依赖如下：父项目：<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://m... 继续阅读 >

2020
10-10

SpringBoot+RabbitMQ方式收发消息的实现示例

本篇会和SpringBoot做整合，采用自动配置的方式进行开发，我们只需要声明RabbitMQ地址就可以了，关于各种创建连接关闭连接的事都由Spring帮我们了~交给Spring帮我们管理连接可以让我们专注于业务逻辑，就像声明式事务一样易用，方便又高效。祝有好收获，先赞后看，快乐无限。本文代码：   https://gitee.com/he-erduo/spring-boot-learning-demo https://github.com/he-erduo/spring-boot-learning-demo1.... 继续阅读 >

2020
10-09

Python rabbitMQ如何实现生产消费者模式

（一）安装一个消息中间件，如：rabbitMQ（二）生产者sendmq.pyimportpikaimportsysimporttime#远程rabbitmq服务的配置信息username='admin'#指定远程rabbitmq的用户名密码pwd='admin'ip_addr='10.1.7.7'port_num=5672#消息队列服务的连接和队列的创建credentials=pika.PlainCredentials(username,pwd)connection=pika.BlockingConnection(pika.ConnectionParameters(ip_addr,port_num,'/',credentials))... 继续阅读 >

2020
10-09

c# rabbitmq 简单收发消息的示例代码

发布消息：（生产者）///<summary>///发送消息///</summary>///<paramname="queue">队列名</param>///<paramname="message">消息内容</param>privatestaticvoidPublishInfo(stringqueue,stringmessage){try{varfactory=newConnectionFactory();factory.HostName="localhost";//RabbitMQ服务在本地运行factory.UserName="guest";//用户名... 继续阅读 >

2020
10-09

c# rabbitmq 简单收发消息的示例代码

发布消息：（生产者）///<summary>///发送消息///</summary>///<paramname="queue">队列名</param>///<paramname="message">消息内容</param>privatestaticvoidPublishInfo(stringqueue,stringmessage){try{varfactory=newConnectionFactory();factory.HostName="localhost";//RabbitMQ服务在本地运行factory.UserName="guest";//用户名... 继续阅读 >

2020
10-08

springboot + rabbitmq 如何实现消息确认机制(踩坑经验)

本文收录在个人博客：www.chengxy-nds.top，技术资源共享，一起进步最近部门号召大伙多组织一些技术分享会，说是要活跃公司的技术氛围，但早就看穿一切的我知道，这TM就是为了刷KPI。不过，话说回来这的确是件好事，与其开那些没味的扯皮会，多做技术交流还是很有助于个人成长的。于是乎我主动报名参加了分享，咳咳咳~，真的不是为了那点KPI，就是想和大伙一起学习学习！这次我分享的是springboot+rabbitmq如何实现消息确... 继续阅读 >

2020
09-24

Spring RabbitMQ死信机制原理实例详解

死信队列：没有被及时消费的消息存放的队列，消息没有被及时消费有以下几点原因：1.有消息被拒绝（basic.reject/basic.nack）并且requeue=false2.队列达到最大长度3.消息TTL过期采用死信机制的好处是可以提高系统的稳定性，当消息消费失败后，消息进入死信队列，可以对消息进行补偿，可以达到最终一致性的目标.具体例子如下：@BeanpublicQueuedeadQueue(){returnnewQueue(DEAD_QUEUE_NAME,true);}@BeanpublicDirec... 继续阅读 >

2018
06-14

IM系统的MQ消息中间件选型：Kafka还是RabbitMQ？

1、前言在IM这种讲究高并发、高消息吞吐的互联网场景下，MQ消息中间件是个很重要的基础设施，它在IM系统的服务端架构中担当消息中转、消息削峰、消息交换异步化等等角色，当然MQ消息中间件的作用远不止于此，它的价值不仅仅存在于技术上，更重要的是改变了以往同步处理消息的思路（比如进行IM消息历史存储时，传统的信息系统作法可能是收到一条消息就马上同步存入数据库，这种作法在小并发量的情况下可以很好的工作，但互联... 继续阅读 >

2017
11-22

Spring Boot与RabbitMQ结合实现延迟队列

顾名思义，延迟队列就是进入该队列的消息会被延迟消费的队列。而一般的队列，消息一旦入队了之后就会被消费者马上消费。延迟队列能做什么？延迟队列多用于需要延迟工作的场景。最常见的是以下两种场景：延迟消费。比如：用户生成订单之后，需要过一段时间校验订单的支付状态，如果订单仍未支付则需要及时地关闭订单。用户注册成功之后，需要过一段时间比如一周后校验用户的使用情况，如果... 继续阅读 >