1.RocketMQ概述 RocketMQ产品支持集群,效率高,同时支持上万队列,支持消息持久化,重试机制等等 2.RocketMQ原理 有别于其他消息中间件由broker做负载均衡并主动向consumer投递消息,RocketMq是基于拉模式拉取消息,consumer做负载均衡并通过长轮询向bro ...
分类:
其他好文 时间:
2020-02-17 19:43:12
阅读次数:
94
一、目录展示 二、导入依赖 <dependency> <groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>3.0.10</version> </dependency> <d ...
分类:
编程语言 时间:
2020-02-17 18:18:45
阅读次数:
131
RocketMQ: 支持集群,效率高,同时支持上万队列,支持消息持久化,重试机制等等; RocketMQ包含的组件 NameServer:单点,供Producer和Consumer获取Broker地址 Producer:产生并发送消息 Consumer:接受并消费消息 Broker:消息暂存,消息转 ...
分类:
其他好文 时间:
2020-02-17 17:49:19
阅读次数:
77
事先说明 1.安装RocketMQ需要Java环境的支持 2.两主两从为了演示效果,就使用两台虚拟机 3.两条虚拟机的端口分别是 A:192.168.118.3 B:192.168.118.4 4.A机器是(A主)同时也是(B从),B机器是(B主)同时也是(A从) 1.下载安装包 1.官网下载 ht ...
分类:
其他好文 时间:
2020-02-17 16:24:15
阅读次数:
121
创建工程(Producer和Consumer) 导入依赖 <dependency> <groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>3.0.10</version> < ...
分类:
编程语言 时间:
2020-02-17 16:11:14
阅读次数:
110
1.安装JDK 1.1 检查当前虚拟机环境有没有JDK rpm -qa|grep java 1.2 卸载 rpm -e --nodeps xxxxxx(自己的openjdk) 1.3 安装JDK 在/usr/local新建一个java文件夹,然后将tar包上传到文件夹下 切换到/usr/local/ ...
分类:
系统相关 时间:
2020-02-17 14:21:39
阅读次数:
88
RocketMQ是什么 是一个队列模型的消息中间件,具有高性能,高可靠,高实时,分布式特点; Producer,Consumer,队列都可以分布式; Producer向一些队列轮流发送消息,队列集合称为Topic,Consumer如果做广播消费,则一个consumer实例消费这个Topic对应的素有 ...
分类:
其他好文 时间:
2020-02-17 14:09:58
阅读次数:
67
github: https://github.com/apache/rocketmq-externals 解压后,直接用idea打开rocketmq-console项目。 修改配置: 删除pom.xml中的: <plugin> <groupId>org.apache.maven.plugins</g ...
分类:
Web程序 时间:
2020-02-17 00:49:42
阅读次数:
1313
消息队列的基本原理 消息队列是基于队列实现的,存储具有特定格式的消息数据。消息队列包括生产者,消息队列以及消费者。 RocketMQ的原理与工作机制 架构图 NameServer Cluster:名字服务器集群,类似于kafka中的zookeeper,提供分布式协调与管理的功能 Producer C ...
分类:
其他好文 时间:
2020-02-15 11:46:33
阅读次数:
63
部署RocketMQ 双Master-Slave 集群架构 问题总结
分类:
其他好文 时间:
2020-02-11 17:43:40
阅读次数:
73