1.特性 1)高吞吐量、低延迟 2)支持热扩展 3)支持高并发 2.组成 Producer 特指消息的生产者 Consumer 特指消息的消费者 Consumer Group 消费者组,可以并行消费Topic中partition的消息 Broker:缓存代理,Kafa 集群中的一台或多台服务器统称为 ...
分类:
其他好文 时间:
2019-10-02 18:52:29
阅读次数:
104
mysql 的 binlog 日志 和slow慢日志 详解 mysql一般常用的日志有三种:1:error错误日志2: binlog日志3:slow日志 下面将详细解释这三种日志: 1、错误日志记录MySQL启动或工作过程中,数据库状态信息,默认就是开启的,数据路径下$hostname.err。也可 ...
分类:
数据库 时间:
2019-10-02 15:00:43
阅读次数:
153
dubbo实质是一个jar,可通过maven引入 服务提供者(Provider):暴露服务的服务提供方,服务提供者在启动时,向注册中心注册自己提供的服务。 服务消费者(Consumer): 调用远程服务的服务消费方,服务消费者在启动时,向注册中心订阅自己所需的服务,服务消费者,从提供者地址列表中,基 ...
分类:
其他好文 时间:
2019-10-02 14:59:41
阅读次数:
89
Redis发布消息模式 生产消费模型 Redis发布消息通常有两种模式: 1:队列模式(queuing) 2:发布-订阅模式(publish-subscribe) 任务队列:顾名思义,就是“传递消息的队列”。与任务队列进行交互的实体有两类,一类是生产者(producer),另一类则是消费者(cons ...
分类:
其他好文 时间:
2019-10-02 14:33:06
阅读次数:
81
1.消息中间件 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。对于消息中间件,常见的角色大致也就有Producer(生产者)、Consumer(消费者)。 2.常见的中间件产品 ...
分类:
其他好文 时间:
2019-09-30 21:40:55
阅读次数:
186
REPORT YTEST_WEBSERVICE_N . DATA LS_CONSUMER TYPE REF TO ZCL_CO_ZWS_ZPPT006M . DATA LS_INPUT TYPE ZCL_ZWS_ZPPT006M . DATA LS_OUTPUT TYPE ZCL_ZWS_ZPPT0... ...
分类:
Web程序 时间:
2019-09-30 09:18:59
阅读次数:
101
匿名内部类 匿名内部类在日常编程中还是经常会使用的。比如 lamda 是java 8的新特性。配合java8的stream流处理,特别的方便 java里还有一个函数接口,在编写中也会用lamda去表示,这样简单一点 + Function + Consumer + Predicate + Suppli ...
分类:
其他好文 时间:
2019-09-29 23:55:11
阅读次数:
200
一、broker参数 broker.id:kafka集群的唯一标识。 log.dirs:kafka存储消息日志的目录,多个用逗号隔开,需要保证指定的目录有充足的磁盘空间。 zookeeper.connect:必须配置,指定kafka集群注册的zookeeper集群的地址。格式是:[主机名]:端口,多 ...
分类:
其他好文 时间:
2019-09-29 12:54:03
阅读次数:
366
工作这么久了.从来没有一个家公司不会强调注释的重要性.究其原因,我觉得下图能够解释. 一图胜千言,但是,不幸的是,程序员90%的时间在阅读代码.不管是别人的还是自己的.程序员的字符浪漫,不仅仅是提现在抽象和代码上.有更多的浪漫体现在其他的方面. 先用欣赏一下linux的一个注释. 位置在:linux ...
分类:
其他好文 时间:
2019-09-29 09:44:59
阅读次数:
95
异步队列的实现。 如下图所示 这里的异步实现,采用redis作为单向的任务队列,将事件通过序列存入redis队列,通过反序列化将其发送给事件消费者。 事件消费者,通过一个EventHandler接口,来处理不同的事件。 事件分发器通过向jedisqueue lpush事件,consumer 从jed ...
分类:
其他好文 时间:
2019-09-28 00:48:16
阅读次数:
115