参考 https://github.com/apache/rocketmq/tree/master/docs/cn RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。B ...
分类：
其他好文 时间：
2020-06-05 15:32:59
阅读次数：
81
我们这里的dubbo-consumer是dubbo-demo-service的消费者： 我们之前已经在jenkins配置好了流水线，只需要填写参数就行了。 由于dubbo-consumer用的gitee的私有仓库，需要添加公钥，这里大家可以自己找个client服务来做实验。 1.jenkins构建 ...
分类：
Web程序 时间：
2020-06-04 13:49:21
阅读次数：
93
链表的一个结点的结构体如下： type LNode struct { value int next *LNode } 对于一个单链表，如果他要存在环，那么至少存在两个节点，也就是说最后一个结点的next指向了前面的某个结点。 所以在判断链表是否存在环的时候，我们添加快慢两个指针fast和slow，f ...
分类：
其他好文 时间：
2020-06-04 13:36:46
阅读次数：
69
- 使用interrupt来请求的好处 可以保证数据的安全，将决定权留给被中断的线程 - 想要停止线程需要请求方， 被停止方， 子方法被调用方相互配合 请求方：需要发出interrput请求 被停止方：需要对interrupt作出响应，在可能抛出InterruptedException的地方作出处理 ...
分类：
编程语言 时间：
2020-06-03 00:50:34
阅读次数：
74
一、kafka的基础架构 1）Producer ：消息生产者，就是向kafka broker发消息的客户端； 2）Consumer ：消息消费者，向kafka broker取消息的客户端； 3）Consumer Group （CG）：消费者组，由多个consumer组成。消费者组内每个消费者负责消费 ...
分类：
其他好文 时间：
2020-06-02 11:14:14
阅读次数：
69
思路 本题设置的条件很特殊 ，解法反常规，用时间换空间 我也只能想到哈希解法 该解法还不符合要求2 参考各种题解 收集以下解法（不局限于题设要求） 哈希 /** * 使用HashMap 2ms 但不能满足 要求2 */ public static int findDuplicate(int[] nu ...
分类：
其他好文 时间：
2020-05-30 21:42:31
阅读次数：
83
上一节消息重试里面提到了重试的消息可以被延时消费，其实除此之外，用户发送的消息也可以指定延时时间（更准确的说是延时等级），然后在指定延时时间之后投递消息，然后被consumer消费。阿里云的ons还支持定时消息，而且延时消息是直接指定延时时间，其实阿里云的延时消息也是定时消息的另一种表述方式，都是通 ...
分类：
其他好文 时间：
2020-05-30 20:23:30
阅读次数：
575
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。 private SendResult sendDefaultImpl( Message msg ...
分类：
其他好文 时间：
2020-05-30 19:45:44
阅读次数：
61
前言 MySQL中有以下日志文件，分别是： 1：重做日志（redo log） 2：回滚日志（undo log） 3：二进制日志（binlog） 4：错误日志（errorlog） 5：慢查询日志（slow query log） 6：一般查询日志（general log） 7：中继日志（relay lo ...
分类：
数据库 时间：
2020-05-30 10:58:00
阅读次数：
93
1.Confirm消息确认机制 消息的确认：是指生产者投递消息后，如果Broker收到消息，则会给生产者一个应答。 生产者进行接收应答，用来确定这条消息是否正常的发送到Broker，这种方式也是消息的可靠性投递的核心保障。 生产端 public static void main(String[] a ...
分类：
其他好文 时间：
2020-05-29 13:36:50
阅读次数：
47
