rocketmq第三方库只支持mac和Linux，需注意！！ #*encoding=utf-8 from rocketmq.client import PullConsumer consumer = PullConsumer('CID_XXX') consumer.set_namesrv_addr( ...
分类：
编程语言 时间：
2020-06-06 18:34:00
阅读次数：
298
急速入门 - 消息生成与消费 1. ConnectionFactory ： 获取连接工厂 2. Connection ： 一个连接 3. Channel：数据通信信道，可发送和接收消息 4. Queue：具体的消息存储队列 5. Producer & Consumer 生产者和消费者 RabbitM ...
分类：
其他好文 时间：
2020-06-06 13:17:57
阅读次数：
56
Predicate函数编程 Predicate功能判断输入的对象是否符合某个条件。官方文档解释到：Determines if the input object matches some criteria. 了解Predicate接口作用后，在学习Predicate函数编程前，先看一下Java 8关于 ...
分类：
编程语言 时间：
2020-06-05 22:56:55
阅读次数：
79
java.util.function中 Function, Supplier, Consumer, Predicate和其他函数式接口广泛用在支持lambda表达式的API中。这些接口有一个抽象方法，会被lambda表达式的定义所覆盖。 Consumer的作用顾名思义,是给定义一个参数,对其进行(消 ...
分类：
其他好文 时间：
2020-06-05 22:52:16
阅读次数：
90
参考 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
- 使用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
上一节消息重试里面提到了重试的消息可以被延时消费，其实除此之外，用户发送的消息也可以指定延时时间（更准确的说是延时等级），然后在指定延时时间之后投递消息，然后被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
