Kafka应用场景 消息系统或是说消息队列中间件是当前处理大数据一个非常重要的组件，用来解决应用解耦、异步通信、流量控制等问题，从而构建一个高效、灵活、消息同步和异步传输处理、存储转发、可伸缩和最终一致性的稳定系统。当前比较流行的消息中间件有Kafka、RocketMQ、RabbitMQ、ZeroM ...
分类：
其他好文 时间：
2019-01-29 14:55:35
阅读次数：
129
对于一个生产者来说，在进行sendmessage的时候，需要知道这个topic应该发给哪个broker。如果没有路由信息的话，需要取注册中心，通过GET_ROUTEINTO_BY_TOPIC去注册中心拿到消息。 介绍下面具体流程之前，还是先介绍注册额中心里面路由管理者RouteInfoManager ...
分类：
其他好文 时间：
2019-01-27 19:20:19
阅读次数：
229
一个haservice下面有accpet和haclient分别对应客户端和服务端，grouptranserservie用来控制消息是否获取到，下面具体讲。 拿haclient举例子，在主线程做的事情 也就是在rocketmq里面，一个具体的任务就是单独分配一个线程，从而发挥多线程优势，在主线程上面休 ...
分类：
其他好文 时间：
2019-01-27 16:35:46
阅读次数：
185
在发送小消息的场景中,三个消息中间件的表现区分明显: Kafka的吞吐量高达17.3w/s,远超其他两个产品。这主要取决于它的队列模式保证了写磁盘的过程是线性IO。此时broker磁盘IO已达瓶颈。 RocketMQ也表现不俗,吞吐量在11.6w/s,磁盘IO %util已接近100%。Rocket ...
分类：
其他好文 时间：
2019-01-26 22:38:02
阅读次数：
245
Netty快速入门 什么是Netty Netty 是一个基于 JAVA NIO 类库的异步通信框架，它的架构特点是：异步非阻塞、基于事件驱动、高性能、高可靠性和高可定制性。 Netty应用场景 1.分布式开源框架中dubbo、Zookeeper，RocketMQ底层rpc通讯使用就是netty。 2 ...
分类：
Web程序 时间：
2019-01-26 11:17:07
阅读次数：
234
https://blog.csdn.net/jiangyu1013/article/details/81668671 消息中间件的作用 1. 应用解耦 2. 异步处理 比如用户注册场景，注册主流程完成以后，需要调用邮件系统发送邮件通知用户注册成功，可能还需要调用其他系统。这是串行的，如果一个系统依赖 ...
分类：
其他好文 时间：
2019-01-23 11:31:57
阅读次数：
193
用两台服务器，搭建出一个双master双slave、无单点故障的高可用 RocketMQ 集群。此处假设两台服务器的物理 IP 分别为：192.168.50.1、192.168.50.2。 内容目录 1. 启动 NameServer 集群 2. 启动 Broker 集群 3. RocketMQ 可视 ...
分类：
其他好文 时间：
2019-01-21 20:06:06
阅读次数：
209
内容目录 1. RocketMQ是什么？ 2. 下载并解压 3. 启动NameServer 4. 启动 Broker 5. 关闭消息队列 1. RocketMQ是什么？ RocketMQ是一种消息队列。何为消息队列？即数据结构中一种“先进先出”的数据结构。在微服务中，分布式消息队列可以解决什么问题？ ...
分类：
其他好文 时间：
2019-01-21 00:32:03
阅读次数：
331
原文:Kafka、ActiveMQ、RabbitMQ、RocketMQ 区别以及高可用原理为什么使用消息队列 其实就是问问你消息队列都有哪些使用场景，然后你项目里具体是什么场景，说说你在这个场景里用消息队列是什么？ 面试官问你这个问题，期望的一个回答是说，你们公司有个什么业务场景，这个业务场景有个什... ...
分类：
其他好文 时间：
2019-01-18 18:32:40
阅读次数：
151
设及技术：springboot、httpClient、apollo、rocketMQ、swagger、eurake 1、从svn下载项目，项目是以模块形式，直接打开文件夹，发现项目层级划分已经存在。 单独一个项目的打开是打卡pom文件，这里多个模块一起打开，不是文件格式是因为.iml intelli ...
分类：
其他好文 时间：
2019-01-15 17:06:15
阅读次数：
209
