发布订阅模式是 生产者 通过这个路由发送到绑定额多个队列中去,然后不同的 消费者 消费不同的队列 从而做到发布订阅模式 1. 生产者 using RabbitMQMsgProducer.MessageProducer; using Microsoft.Extensions.Configuration ...
分类：
其他好文 时间：
2021-01-19 12:14:10
阅读次数：
0
收集日志后，日志级别分类，error 级别发送运维邮件需单独处理，其他记录 直接交换机，工作方式类似于单播，Exchange会将消息发送完全匹配Routing_key的Queue；筛选消息通过key进行； 1. 生产者 using RabbitMQMsgProducer.MessageProduce ...
分类：
其他好文 时间：
2021-01-19 12:13:34
阅读次数：
0
（1）消费消息失败后，重新加入队列并优先级处理； （2）根据消息的内容筛选出优先级高的进行设置，并发送 1. 生产者 using RabbitMQMsgProducer.MessageProducer; using Microsoft.Extensions.Configuration; using ...
分类：
其他好文 时间：
2021-01-19 12:12:57
阅读次数：
0
订单多任务处理 能够让生产者的横向扩展，支持多个服务器； 生产者集群架构，消费端集群架构； 同一个队列的话，消息是被瓜分掉的 设置均衡消费端： channel.BasicQos(0, 1, false); //预取数量设置为1个; 设置false nuget ： 1. 生产者 using Rabbi ...
分类：
其他好文 时间：
2021-01-19 12:11:54
阅读次数：
0
Conditon中的await()对应Object的wait()，Condition中的signal()对应Object的notify()，Condition中的signalAll()对应Object的notifyAll() 两个线程交替执行例子（同理生产者消费者也是这样交替执行）： package ...
分类：
其他好文 时间：
2021-01-18 11:05:41
阅读次数：
0
生产者 KafkaExtendProducer.send("topic","key","value"); 消费者 @Slf4j @RequiredArgsConstructor @Component public class ConsumerThread implements Runnable { ...
分类：
其他好文 时间：
2021-01-15 11:46:10
阅读次数：
0
一、pom.xml导入依赖 <dependencies> <!-- activemq 所需要的jar 包--> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <ver ...
分布式分为分布式缓存（Redis）、分布式锁（Redis 或 Zookeeper）、分布式服务（Dubbo 或 SpringCloud）、分布式服务协调（Zookeeper）、分布式消息队列（Kafka 、RabbitMq）、分布式 Session 、分布式事务、分布式搜索（Elasticsearc ...
分类：
其他好文 时间：
2021-01-04 11:02:16
阅读次数：
0
本文通过全面的介绍 ZooKeeper，希望帮助读者加深对 ZooKeeper 的认知。
分类：
其他好文 时间：
2021-01-02 10:56:58
阅读次数：
0
DelayQueue 顾名思义,它是一个延时队列 使用方式 : 假设我们生产者提交一个任务，消费者5秒钟之后才可以执行，那么我们可以把任务定义为如下格式，并实现Delayed接口，其中data是任务存储的信息。 /** * 具体的任务 * @author wangshixiang */ public ...
分类：
其他好文 时间：
2020-12-25 11:47:01
阅读次数：
0
