RocketMQ学习

写在前面

简单说明一下,RocketMQ是阿里团队开发,并推到Apache社区,它的入门稍微有点难(主要是环境、网络、社区的资源有限),下面我简单介绍一下

一、安装、部署

这里包括三个

  • Windows单机
  • Linux单机
  • linux多主多从

上文中说到的难点就是,Linux 的版本学习,本地可以部署成功,但客户端Client连接,总是连接不上

这里我先介绍下 本地Windows的版本学习

1.1、Windows单机版

1.1.1、基本环境

  • 64bit
  • 64bit JDK 1.8+;
  • Maven
  • Git

三种安装方式,

  • 源码
  • 二进制文件
  • docker

这里我介绍下,二进制的安装方式

下载

然后 解压 -> 配置环境变量 -> 修改配置 -> 启动 nameserver -> 启动 broker

1.1.2、需要注意的地方

  • 配置环境变量 ,一定要 用 ROCKETMQ_HOME 来标识
  • 修改配置,单机版,只要修改 启动配置即可

在这里插入图片描述
修改 这两个配置文件的启动 内存分配,调小 如下

-server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m

1.1.3、启动服务

  • 先启动 mqnamesrv.cmd

  • 再启动 mqbroker.cmd
    注意启动Broker 时,指定 自动生成Topic

    start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

在这里插入图片描述

在这里插入图片描述

1.1.、配置控制台

这里,我有 打好的包,在这里(仅适合本地单机版)
https://kdocs.cn/l/ce6BAkTZo
[金山文档] rocketmq-console-ng-1.0.1.jar

也可从官网,下载源码,修改nameserver 配置,编译,打包,执行

Github 地址

二、基本命令

三、 客户端学习

可参考,Springboot 集成 RocketMQ 的三种方式

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

2020年前端实用代码段,为你的工作保驾护航

有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )