业务背景跟第三方系统做对接，双方通过ActiveMQ进行通信，消息之间是有内在关联的，也就是消息本来应该是有业务顺序的，但由于一些原因，现在收到消息是乱序的，这种情况下做业务处理就有一点小问题了方案一：自己重排序收到消息后，自己在内存排序，然后按顺序丢到队列中，自己控制消息的发送和接收保证收到按发送的顺序来收到消息。如果自己排序的话就要对每个消息标记一个顺序，同时还要指定预先定义好哪些消息属于一类并且相互之间有依赖顺序。具体实现的话，可以这样做：1、收到一条消息，封装一下加个序号，放到Redis中，用列表或者有序集合来存储，同时用字符串类型存一下这个业务单号的当前最小序号（默认是1）2、如果是
业务背景跟第三方系统做对接，双方通过ActiveMQ进行通信，消息之间是有内在关联的，也就是消息本来应该是有业务顺序的，但由于一些原因，现在收到消息是乱序的，这种情况下做业务处理就有一点小问题了方案一：自己重排序收到消息后，自己在内存排序，然后按顺序丢到队列中，自己控制消息的发送和接收保证收到按发送的顺序来收到消息。如果自己排序的话就要对每个消息标记一个顺序，同时还要指定预先定义好哪些消息属于一类并且相互之间有依赖顺序。具体实现的话，可以这样做：1、收到一条消息，封装一下加个序号，放到Redis中，用列表或者有序集合来存储，同时用字符串类型存一下这个业务单号的当前最小序号（默认是1）2、如果是
一、前言 消息队列（MessageQueue）是分布式系统必不可少的中间件，大部分消息队列产品（如RocketMQ/RabbitMQ/Kafka等）要求团队有比较强的技术实力，不适用于中小团队，并且对.NET技术的支持力度不够。而Redis实现的轻量级消息队列很简单，仅有Redis常规操作，几乎不需要开发团队掌握额外的知识！ 写这篇文档的目的，是因为在最近开发过程中，需要用到多端订阅的功能，之前设计的时候用的是rockemq，最近又重新整理了一遍项目架构，把orm替换成了二次封装的shinysqlsugar,redis也替换成了shiny.redis，正好看到newlife.redis已经实现
一、前言 消息队列（MessageQueue）是分布式系统必不可少的中间件，大部分消息队列产品（如RocketMQ/RabbitMQ/Kafka等）要求团队有比较强的技术实力，不适用于中小团队，并且对.NET技术的支持力度不够。而Redis实现的轻量级消息队列很简单，仅有Redis常规操作，几乎不需要开发团队掌握额外的知识！ 写这篇文档的目的，是因为在最近开发过程中，需要用到多端订阅的功能，之前设计的时候用的是rockemq，最近又重新整理了一遍项目架构，把orm替换成了二次封装的shinysqlsugar,redis也替换成了shiny.redis，正好看到newlife.redis已经实现
1.你们为什么使用mq？具体的使用场景是什么？ mq的作用很简单，削峰填谷。以电商交易下单的场景来说，正向交易的过程可能涉及到创建订单、扣减库存、扣减活动预算、扣减积分等等。每个接口的耗时如果是100ms，那么理论上整个下单的链路就需要耗费400ms，这个时间显然是太长了。 如果这些操作全部同步处理的话，首先调用链路太长影响接口性能，其次分布式事务的问题很难处理，这时候像扣减预算和积分这种对实时一致性要求没有那么高的请求，完全就可以通过mq异步的方式去处理了。同时，考虑到异步带来的不一致的问题，我们可以通过job去重试保证接口调用成功，而且一般公司都会有核对的平台，比如下单成功但是未
1.你们为什么使用mq？具体的使用场景是什么？ mq的作用很简单，削峰填谷。以电商交易下单的场景来说，正向交易的过程可能涉及到创建订单、扣减库存、扣减活动预算、扣减积分等等。每个接口的耗时如果是100ms，那么理论上整个下单的链路就需要耗费400ms，这个时间显然是太长了。 如果这些操作全部同步处理的话，首先调用链路太长影响接口性能，其次分布式事务的问题很难处理，这时候像扣减预算和积分这种对实时一致性要求没有那么高的请求，完全就可以通过mq异步的方式去处理了。同时，考虑到异步带来的不一致的问题，我们可以通过job去重试保证接口调用成功，而且一般公司都会有核对的平台，比如下单成功但是未
在《深入理解Java类加载机制，再也不用死记硬背了》里我提到了对于一门语言的“会”的三个层次。本篇将以知识地图的形式展现学习消息中间件MQ各个层次要掌握的内容。 知识地图是一种知识导航系统，并显示不同的知识存储之间重要的动态联系。所以本篇重点不是介绍某个知识点，而是介绍掌握消息中间件，需要看哪些文章的导航。 消息中间件MQ会的三个层次与黄金圈法则相对应。 What层：helloworld级别 What层：hello world级别，知道它能做什么。在《RabbitMQ设计原理解析》里详细介绍过，这里再讲一遍。 MQ的主要作用有三个： 1、异步处理 示例一：在《架构师三大难-领域划分问题》的示
在《深入理解Java类加载机制，再也不用死记硬背了》里我提到了对于一门语言的“会”的三个层次。本篇将以知识地图的形式展现学习消息中间件MQ各个层次要掌握的内容。 知识地图是一种知识导航系统，并显示不同的知识存储之间重要的动态联系。所以本篇重点不是介绍某个知识点，而是介绍掌握消息中间件，需要看哪些文章的导航。 消息中间件MQ会的三个层次与黄金圈法则相对应。 What层：helloworld级别 What层：hello world级别，知道它能做什么。在《RabbitMQ设计原理解析》里详细介绍过，这里再讲一遍。 MQ的主要作用有三个： 1、异步处理 示例一：在《架构师三大难-领域划分问题》的示
项目场景实现一个商品秒杀的功能，能后台自定义秒杀时间段、商品库存等信息。一、设计思路这里简单分享下思路：1.限流秒杀时大量用户会在同一时间同时进行抢购，网站瞬时访问流量激增，由于只有少部分用户能够秒杀成功，所以要限制大部分流量，只允许少部分流量进入服务后端。这里使用基于Redis简单粗暴的限流方案：信号量(Semaphore)信号量就是可以被多个线程同时持有的一种同步对象，比如我设置一个值为5的计数信号量，那么现在有十个线程来获取他就只会有五个可以成功，剩下那五个则获取失败。所以说如果有个计数信号量定义的值是1，那么他其实就等同于mutex(互斥锁)2.具体流程这里首先需要明确如何缓存秒杀的商
项目场景实现一个商品秒杀的功能，能后台自定义秒杀时间段、商品库存等信息。一、设计思路这里简单分享下思路：1.限流秒杀时大量用户会在同一时间同时进行抢购，网站瞬时访问流量激增，由于只有少部分用户能够秒杀成功，所以要限制大部分流量，只允许少部分流量进入服务后端。这里使用基于Redis简单粗暴的限流方案：信号量(Semaphore)信号量就是可以被多个线程同时持有的一种同步对象，比如我设置一个值为5的计数信号量，那么现在有十个线程来获取他就只会有五个可以成功，剩下那五个则获取失败。所以说如果有个计数信号量定义的值是1，那么他其实就等同于mutex(互斥锁)2.具体流程这里首先需要明确如何缓存秒杀的商
