最近看到代码中有语法糖，记录一下， 1.重写，只能重写，属性，虚方法（virtual）,子类重写用override private string apublic string A{get =>“123”；set =>a=value;} 2.定义静态变量赋值 private static Lazy<K ...
rocketMq建立监听： 一个groupId下通常会挂载多个consumer实例。 集群订阅方式 (默认)：一个监听到之后，另一个consumer实例就不会再监听到（不管在不在一个服务器上）。 由于默认集群订阅方式，只能有一个监听到，所以，本地测试和服务器上topic不能一致，否则会影响服务器上监 ...
分类：
其他好文 时间：
2019-07-04 21:28:58
阅读次数：
163
1.引入jar 2.kafka producer 3.consumer ...
分类：
其他好文 时间：
2019-07-04 11:24:00
阅读次数：
75
系统运维的过程中，每一个细节都值得我们关注 下图为我们的基本日志处理架构 所有日志由Rsyslog或者Filebeat收集，然后传输给Kafka，Logstash作为Consumer消费Kafka里边的数据，分别写入Elasticsearch和Hadoop，最后使用Kibana输出到web端供相关人 ...
分类：
其他好文 时间：
2019-07-04 09:27:39
阅读次数：
137
1、kafka的配置 2、topic的配置 3、producer的配置 4、consumer的配置 props.put("consumer.timeout.ms", "100"); 这个配置很重要，关乎取消息的阻塞的时间 默认-1,consumer在没有新消息时无限期的block。如果设置一个正值， ...
分类：
其他好文 时间：
2019-07-02 13:29:18
阅读次数：
81
RocketMQ重试机制 消息重试分为两种： Producer发送消息的重试 和 Consumer消息消费的重试 。 一、Producer端重试 Producer端重试是指: Producer往MQ上发消息没有发送成功，比如网络原因导致生产者发送消息到MQ失败。 看一下代码： 针对网上说的超时异常会 ...
分类：
其他好文 时间：
2019-07-02 00:17:20
阅读次数：
80
主题+客户端发布订阅的对象是主题（Topic）向主题发布消息的客户端应用程序称为生产者（Producer），生产者可以持续不断地向多个主题发送消息订阅这些主题消息的客户端应用程序称为消费者（Consumer），消费者能够同时订阅多个主题的消息生产者和消费者统称为客户端服务端Kafka的服务端由被称为Broker的服务进程构成，一个Kafka集群由多个Broker组成Broker负责接收和处理客户端
分类：
编程语言 时间：
2019-07-01 21:41:06
阅读次数：
169
一、队列消费者集群（Queueconsumerclusters） ActiveMQ支持Consumer对消息高可靠性的负载平衡消费，如果一个Consumer死掉，该消息会转发到其他的Consumer消费的Queue上。如果一个Consumer获得消息比其它的Consumer快，那么它将获得更多的消息。因此推荐ActiveMQ的Broker和
分类：
其他好文 时间：
2019-07-01 00:45:06
阅读次数：
105
一、独有消费者 Queue中的消息是按照顺序被分发到consumers的，然而，当有多个consumers同时从相同的queue中提取消息时，你将失去这个保证。因为这些消息是被多个多线程并发的处理。有的时候，保证消息按照顺序处理是很重要的，但是你可能不希望在插入订单操作结束之前执行更新这个订单的操作。 Ac
分类：
其他好文 时间：
2019-07-01 00:33:33
阅读次数：
84
return listener 用于处理一些不可路由的消息。 我们的消息生产者，通过指定一个exchange和routingkey，把消息送达到某一个队列中，然后我们的消费者监听队列，进行消费处理操作。 但是在某种情况下，如果我们在发送消息的时候，当前的exchange不存在或者制定的路由key路由 ...
分类：
其他好文 时间：
2019-06-29 19:33:35
阅读次数：
220
