• 欢迎访问 winrains 的个人网站!
  • 本网站主要从互联网整理和收集了与Java、网络安全、Linux等技术相关的文章,供学习和研究使用。如有侵权,请留言告知,谢谢!

6种延时队列的实现方案

6种延时队列的实现方案
五一期间原计划是写两篇文章,看一本技术类书籍,结果这五天由于自律性过于差,禁不住各种诱惑,我连电脑都没打开过,计划完美宣告失败。所以在这能看出和大佬之间的差距,人家没白没夜的更文,比你优秀的人比你更努力,难以望其项背,真是让我自愧不如。 知耻而后勇,这不逼着自己又学起来了,个人比较喜欢一些实践类的东西,既学习到知识又能让技术落地,能搞出个demo最好,本……继续阅读 »

winrains 3个月前 (07-27) 45浏览 0个赞

SpringBoot + RabbitMQ 消息确认机制

SpringBoot + RabbitMQ 消息确认机制
这次我分享的是 springboot + rabbitmq 如何实现消息确认机制,以及在实际开发中的一点踩坑经验,其实整体的内容比较简单,有时候事情就是这么神奇,越是简单的东西就越容易出错。 可以看到使用了 RabbitMQ 以后,我们的业务链路明显变长了,虽然做到了系统间的解耦,但可能造成消息丢失的场景也增加了。例如: 消息生产者 – ……继续阅读 »

winrains 3个月前 (07-27) 130浏览 0个赞

RocketMq之事务消息实现原理

RocketMq之事务消息实现原理
RocketMQ提供了事务消息的功能,采用2PC(两段式协议)+补偿机制(事务回查)的分布式事务功能,通过消息队列 RocketMQ 版事务消息能达到分布式事务的最终一致。 概览 半事务消息:暂不能投递的消息,发送方已经成功地将消息发送到了消息队列 RocketMQ 版服务端,但是服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状……继续阅读 »

winrains 4个月前 (06-28) 68浏览 3个赞

RocketMq之Broker源码分析

RocketMq之Broker源码分析
服务器上部署的RocketMq进程一般称之为Broker,Broker会接收Producer的消息,持久化到本地,然后push给Consumer,通常使用集群部署,主从之间会有数据同步。 Broker与NameSever Broker 会向所有 NameSever 注册自己(包含topic信息),并保持心跳连接。 连接单个broker和所有namese……继续阅读 »

winrains 4个月前 (06-28) 81浏览 3个赞

RocketMq之Consumer原理浅析

RocketMq之Consumer原理浅析
Consumer是怎么启动的 源码很长,这里就不仔细看了,其实主要就是初始化了三个组件,然后启动后台定时任务 RebalanceImpl 均衡消息队列服务,负责分配当前 Consumer 可消费的消息队列( MessageQueue )。当有新的 Consumer 的加入或移除,都会重新分配消息队列。 PullAPIWrapper 拉取消息组件 o……继续阅读 »

winrains 4个月前 (06-28) 52浏览 3个赞

RocketMq之NameSever浅析

RocketMq之NameSever浅析
NameSever 是一种路由服务,类似于dubbo中的注册中心zk,它存储了Broker的路由信息,供Producer和Consumer使用,不然Producer怎么知道往哪个Broker发送消息。多个NameSever之间没有通信,每个NameSever都会保存所有路由信息。 NameSever的启动 NameSever 是通过命令行在服务器上启动的,通……继续阅读 »

winrains 4个月前 (06-28) 58浏览 3个赞

Spring Boot 高级篇–RabbitMQ(5):RabbitListener消费基本使用姿势介绍

Spring Boot 高级篇–RabbitMQ(5):RabbitListener消费基本使用姿势介绍
之前介绍了rabbitmq的消息发送姿势,既然有发送,当然就得有消费者,在SpringBoot环境下,消费可以说比较简单了,借助@RabbitListener注解,基本上可以满足你90%以上的业务开发需求 下面我们来看一下@RabbitListener的最最常用使用姿势 I. 配置 首先创建一个SpringBoot项目,用于后续的演示 springboot……继续阅读 »

winrains 7个月前 (04-13) 54浏览 2个赞

Spring Boot 高级篇–RabbitMQ(4):RabbitMq消息确认机制/事务的使用姿势

Spring Boot 高级篇–RabbitMQ(4):RabbitMq消息确认机制/事务的使用姿势
上一篇介绍了RabbitMq借助RabbitTemplate来发送消息的基本使用姿势,我们知道RabbitMq提供了两种机制,来确保发送端的消息被brocke正确接收,本文将主要介绍,在消息确认和事物两种机制的场景下,发送消息的使用姿势 I. 配置 首先创建一个SpringBoot项目,用于后续的演示 springboot版本为2.2.1.RELEASE ……继续阅读 »

winrains 7个月前 (04-13) 353浏览 3个赞

Spring Boot 高级篇–RabbitMQ(3):发送消息基本使用姿势

Spring Boot 高级篇–RabbitMQ(3):发送消息基本使用姿势
前面两篇博文,分别介绍了RabbitMq的核心知识点,以及整合SpringBoot的demo应用;接下来也该进入正题,看一下SpringBoot的环境下,如何玩转rabbitmq 本篇内容主要为消息发送,包括以下几点 RabbitTemplate 发送消息的基本使用姿势 自定义消息基本属性 自定义消息转换器AbstractMessageConverter ……继续阅读 »

winrains 7个月前 (04-13) 56浏览 3个赞

Spring Boot 高级篇–RabbitMQ(2):RabbitMq核心知识点小结

Spring Boot 高级篇–RabbitMQ(2):RabbitMq核心知识点小结
RabbitMQ是一个基于AMQP协议实现的企业级消息系统,想要顺畅的玩耍的前提是得先了解它,本文将主要介绍rabbitmq的一些基本知识点 特点 基本概念 消息投递消费的几种姿势 事务 集群 I. 基本知识点 它是采用Erlang语言实现的AMQP(Advanced Message Queued Protocol)的消息中间件,最初起源于金融系统,用在……继续阅读 »

winrains 7个月前 (04-13) 41浏览 3个赞