1.模式说明 应用场景：对于 任务过重或任务较多情况使用工作队列可以提高任务处理的速度 只有3个角色：P：生产者，也就是要发送消息的程序C：消费者：消息的接受者，会一直等待消息到来。queue：消息队列，图中红色部分 2.应用举例 Producer: 1 /** 2 * 发送消息 3 */ 4 pu ...
分类：
其他好文 时间：
2020-08-18 13:51:39
阅读次数：
63
1. producer MQProducer接口： public interface MQProducer<K, V> { Future<RecordMetadata> send(ProducerRecord<K, V> var1) throws IllegalArgumentException; ...
分类：
其他好文 时间：
2020-08-15 22:27:25
阅读次数：
66
最近看了@JavaGuide发布的一篇『面试官问我如何保证Kafka不丢失消息?我哭了！』，这篇文章承接这个主题，来聊聊如何保证RocketMQ不丢失消息。0x00.消息的发送流程一条消息从生产到被消费，将会经历三个阶段：生产阶段，Producer新建消息，然后通过网络将消息投递给MQBroker存储阶段，消息将会存储在Broker端磁盘中消息阶段，Consumer将会从Broker拉取消息以上任
分类：
其他好文 时间：
2020-08-05 18:15:11
阅读次数：
81
查看消费组详情: ./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group 查看topic详情： ./bin/kafka-topics.sh --to ...
分类：
其他好文 时间：
2020-07-31 18:03:33
阅读次数：
83
一.消息的可靠投递 在使用RabbitMq的时候，作为消息发送方希望杜绝任何消息丢失或者投递失败的场景。RabbitMQ为我们提供了两种方式用来控制消息的投递可靠性 rabbitMQ 整个消息投递过程为： producer -> rabbitMQ broker -> exchange -> queu ...
分类：
其他好文 时间：
2020-07-27 17:53:27
阅读次数：
116
目录1. AOP 概念2. AOP 编程的开发步骤3. 切面的名词解释4. AOP 的底层实现原理4.1 动态代理类的创建4.2 总结5. Spring 工厂如何加工原始对象1. AOP 概念 POP (Producer Oriented Programing） 面向过程（方法、函数）编程 —— C... ...
分类：
编程语言 时间：
2020-07-26 22:55:04
阅读次数：
90
RabbitMq保证消息可靠性之确认模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类：
其他好文 时间：
2020-07-26 01:04:06
阅读次数：
114
RabbitMq保证消息可靠性之回退模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类：
其他好文 时间：
2020-07-26 01:03:17
阅读次数：
81
为了测试Avro Schema的兼容性，新建2个Java project，其中v1代表的是第一个版本， v2代表的是第二个版本。 测试步骤： Run producer-v1，去schema registry UI看schema版本 Run producer-v2，去schema registry U ...
分类：
编程语言 时间：
2020-07-21 21:58:41
阅读次数：
60
package com.sun4cloud.sunx.question.config; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.producer.Producer ...
分类：
其他好文 时间：
2020-07-21 21:29:44
阅读次数：
71
