Kafka中,topic是逻辑上的概念,而partition是物理上的概念。不用担心,这些对用户来说是透明的。生产者(producer)只关心自己将消息发布到哪个topic,而消费者(consumer)只关心自己订阅了哪个topic上的消息,至少topic上的消息分布在哪些partition节点上, ...
分类:
其他好文 时间:
2018-06-08 14:20:54
阅读次数:
171
简介 rabbitmq是一个消息代理系统,为应用提供一个通用得消息发布,接受平台,为应用提供非阻塞的消息系统,方便进行异步处理。 优点 1. 消息的可靠性。持久化消息,消息接受确认,消息重传等可靠机制。 2. 灵活的路由。交换机可以根据广播,或者根据路由键或匹配符匹配到不同的队列。 3. 高可用的集 ...
分类:
其他好文 时间:
2018-05-21 23:04:56
阅读次数:
236
一、kafka的架构 1、Broker kafka集群包含一个或者多个服务器,这种服务器就叫做Broker 2、Topic 每条发布到kafka集群的消息都有一个类别,这个类别就叫做Topic(逻辑上的概念,物理上不同的Topic的消息分开存储,逻辑上一个topic的消息虽然保存于一个或者多个bro ...
分类:
其他好文 时间:
2018-05-09 14:41:49
阅读次数:
132
1、rabbitmq理论1.1、什么叫消息队列 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。1.2、消息队列通信方式 消息队列(MessageQueue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到MQ中而不用管谁来取,
分类:
其他好文 时间:
2018-05-07 23:52:15
阅读次数:
2019
考察一个面向大众的系统开发的是否成功,这个系统在有限时间内能接受的访问数量是一个很重要的标准。在传统的方案中,增加访问数量的方法就是增加服务器。打个比方,如果一台服务器能够支持100个人同时访问,而同时访问这个系统的人有10000个,那么,就提供100台服务器。但是传统的方法中,管理员工程和用户工程 ...
分类:
其他好文 时间:
2018-05-07 22:50:16
阅读次数:
155
在模块化的设计中,对各个模块的解耦是至关重要的,通常我们可以对模块所扮演的角色定义未发布者、订阅者。发布者内部状态发生变化时不用关心谁会响应自己的消息,通过初始的订阅,有notice组件自动分发消息。 ...
分类:
其他好文 时间:
2018-05-05 18:06:27
阅读次数:
187
MQTT简介 MQ 遥测传输 (MQTT) 是轻量级基于代理的发布/订阅的消息传输协议,设计思想是开放、简单、轻量、易于实现。这些特点使它适用于受限环境。该协议的特点有: 使用发布/订阅消息模式,提供一对多的消息发布,解除应用程序耦合。 对负载内容屏蔽的消息传输。 使用 TCP/IP 提供网络连接。 ...
全终端消息推送解决方案 项目介绍 这是一个全终端的消息推送解决方案,实现类似微博的消息发布模式,用户可在移动端,网页端或是PC端发布消息,相应的,其他用户可在上述平台上接收并查看这个用户发送的消息。预计实现基础的注册,登录验证以及发布消息与接收消息功能。 竞争性需求分析框架 N——need,需求 该 ...
分类:
其他好文 时间:
2018-04-20 20:41:35
阅读次数:
186
2014年11月,Python2.7将在2020年停止的消息发布,并且不会再发布2.8版本,建议用户尽量升级至3.4以,上版本,原因是Python在最初发布时,在某些设计上存在一些缺陷,比如Unicode(统一码、万国码、单一码)标准晚于Python出现,所以一直以来对Unicode的支持并不完全, ...
分类:
编程语言 时间:
2018-04-06 10:53:38
阅读次数:
217
什么叫消息队列 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。 消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁 ...
分类:
其他好文 时间:
2018-03-30 17:25:27
阅读次数:
189