RocketMQ部署 Linux方式和Docker方式

这篇具有很好参考价值的文章主要介绍了RocketMQ部署 Linux方式和Docker方式。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、Linux部署

准备一台Linux机器,部署单master rocketmq节点

系统 ip 角色 模式
CENTOS 10.4.7.126 Nameserver,broker Master

1. 配置JDK

rocketmq运行需要依赖jdk,安装步骤略。

2. 下载和配置

  1. 从官网下载安装包 https://rocketmq.apache.org/zh/download/ ,并上传到CENTOS系统中,并进行解压
cd /data
# 解压
unzip rocketmq-all-5.1.3-bin-release.zip
# 创建目录软链接
ln -s rocketmq-all-5.1.3-bin-release rocketmq
# 创建目录
#  消息存储及位点目录
 mkdir -p /data/rocketmq/store
 mkdir -p /data/rocketmq/store/commitlog
 mkdir -p /data/rocketmq/store/consumequeue
 mkdir -p /data/rocketmq/store/index
#  创建日志目录
 mkdir -p /data/rocketmq/logs
# 进入配置文件目录并替换日志配置文件中的日志目录的位置
cd /data/rocketmq/conf && sed -i 's#${user.home}#/data/rocketmq#g' *.xml
 

修改rocketmq启动所需配置文件

# 进入rocketmq自带的配置文件目录
[root@mq-126 conf]# cd /data/rocketmq/conf/
[root@mq-126 conf]# ls
# 2master 2slave 异步消息同步配置目录
2m-2s-async
# 2master 2slave 同步消息同步配置目录
2m-2s-sync
# 2master no slave 配置目录
2m-noslave
# 单点配置目录
broker.conf
container
controller
dledger
plain_acl.yml
# 日志配置文件
rmq.broker.logback.xml
rmq.client.logback.xml
rmq.controller.logback.xml
rmq.namesrv.logback.xml
rmq-proxy.json
rmq.proxy.logback.xml
rmq.tools.logback.xml
tools.yml
[root@mq-126 conf]# vi broker.conf

将下面的配置赋值到broker.conf中

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker 名字,注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master,>0 表示 Slave
brokerId=0
#nameServer 地址,分号分割
namesrvAddr=127.0.0.1:9876
#在发送消息时,自动创建服务器不存在的 topic,默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建 Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点,默认凌晨 4 点
deleteWhen=04
#文件保留时间,默认 48 小时
fileReservedTime=120
#commitLog 每个文件的大小默认 1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue 每个文件默认存 30W 条,根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/data/rocketmq/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq/store/consumequeue #消息索引存储路径
storePathIndex=/data/rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/store/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制 Master
#- SYNC_MASTER 同步双写 Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

修改启动脚本的jvm参数,找到对应行进行修改,原配置设置的内存太大,我的虚拟机是1g内存的,会无法正常启动,需要改小。

  • vim /data/rocketmq/bin/runbroker.sh

    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"
    
  • vim /data/rocketmq/bin/runserver.sh

    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"
    

3. 启动

  1. 启动nameserver

    [root@mq-126 rocketmq]# nohup sh /data/rocketmq/bin/mqnamesrv &
    
    [root@mq-126 rocketmq]# jps
    2617 NamesrvStartup
    2654 Jps
    [root@mq-126 rocketmq]# netstat -ano | grep 9876
    tcp6       0      0 :::9876                 :::*                    LISTEN      off (0.00/0/0)
    tcp6       0      0 10.4.7.126:9876         10.4.7.126:53946        ESTABLISHED off (0.00/0/0)
    tcp6       0      0 10.4.7.126:9876         10.4.7.125:42368        ESTABLISHED off (0.00/0/0)
    tcp6       0      0 10.4.7.126:53946        10.4.7.126:9876         ESTABLISHED off (0.00/0/0)
    
  2. 启动broker

    [root@mq-126 bin]# nohup sh /data/rocketmq/bin/mqbroker -c /data/rocketmq/conf/broker.conf &
    [2] 2829
    [root@mq-126 bin]# jps
    2796 NamesrvStartup
    2861 BrokerStartup
    2893 Jps
    
  3. 启动dashboard

    启动dashboard最快的方式是通过docker进行启动。

    [root@mq-126 bin]# systemctl start docker
    [root@mq-126 bin]# docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=10.4.7.126:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest
    d55cb8b7ff0e9d19964c2019eaf4bba8301cfc2cf1b8a3eb01bff09df134f90e
    

    然后就可以访问dashboard了

    如果没有docker环境 在官网下下载源码包,使用maven编译后进行启动

    https://rocketmq.apache.org/zh/download/

4. 发送和消费测试代码

Producer

package cn.shutdown.mq;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;

/**
 * 消息生产者
 * @author Domino.J
 * @date 2023/8/11
 */
public class Producer {

    public static final String NAMESRV_ADDR = "10.4.7.126:9876";
    public static void main(String[] args)
            throws MQClientException, MQBrokerException, RemotingException, InterruptedException {
        DefaultMQProducer producer = new DefaultMQProducer("test_quick_producer_name");
        producer.setNamesrvAddr(NAMESRV_ADDR);
        producer.start();

        for (int i = 0; i < 1000; i++) {
            Message message = new Message("test_quick_topic",//主题
                    "TagA", //标签
                    "KeyA" + i, //用户自定义的key,唯一的标识
                    ("Hello RocketMQ" + i).getBytes());//消息内容
            //发送消息
            SendResult sr = producer.send(message);
            System.out.println("消息发送结果:" + sr);
            Thread.sleep(1000);
        }
        producer.shutdown();
    }
}

Consumer

package cn.shutdown.mq;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.remoting.common.RemotingHelper;

import java.util.List;

/**
 * 消息消费者
 * @author Domino.J
 * @date 2023/8/11
 */
public class Consumer {

    public static final String NAMESRV_ADDR = "10.4.7.126:9876";

    public static void main(String[] args) throws MQClientException {

        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("test_quick_consumer_name");
        consumer.setNamesrvAddr(NAMESRV_ADDR);
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
        consumer.subscribe("test_quick_topic", "*");
        consumer.registerMessageListener(new MessageListenerConcurrently() {
        	@Override
        	public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                MessageExt me = msgs.get(0);
                try {
                    String topic = me.getTopic();
                    String tags = me.getTags();
                    String keys = me.getKeys();
                    String msgBody = new String(me.getBody(), RemotingHelper.DEFAULT_CHARSET);
                    System.err.println("topic: " + topic + ",tags: " + tags + ", keys: " + keys + ",body: " + msgBody);
                } catch (Exception e) {
                    e.printStackTrace();
                    return ConsumeConcurrentlyStatus.RECONSUME_LATER;
                }
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });

        consumer.start();
        System.err.println("consumer start...");

    }
}

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>cn.shutdown</groupId>
    <artifactId>rocketmq-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>rocketmq-demo</name>
    <description>rocketmq-demo</description>
    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.6.13</spring-boot.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client-java</artifactId>
            <version>5.0.3</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>5.1.3</version>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>${spring-boot.version}</version>
                <configuration>
                    <mainClass>cn.shutdown.mq.RocketmqDemoApplication</mainClass>
                    <skip>true</skip>
                </configuration>
                <executions>
                    <execution>
                        <id>repackage</id>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

运行结果

二、Docker Compose部署

1. 拉取镜像

拉取 rocketmq镜像

docker pull apache/rocketmq:5.1.3

拉取 rocketmq dashboard镜像

docker pull apacherocketmq/rocketmq-dashboard:latest	

2. 创建挂载目录,拷贝挂载文件

  1. 创建Nameserver需要的挂载目录并拷贝挂载文件

    # 日志目录
    mkdir /data/opt/rocketmq/nameserver/logs -p
    # 脚本目录
    mkdir /data/opt/rocketmq/nameserver/bin -p
    

    设置权限:如果不设置会导致NameServer容器内部无法写日志文件

    # 777 文件所属者、文件所属组和其他人有读取 & 写入 & 执行全部权限。rwxrwxrwx
    chmod 777 -R /data/opt/rocketmq/nameserver/*
    

    正如使用Linux部署一样,需要修改JAVA_OPT配置,这里需要从rocketmq容器中复制出一份运行文件,修改后再挂载到新启动的容器上。另外,NameServer启动脚本中有一个自动计算最大堆内存和新生代内存的函数会导致在不同硬件环境下设置最大堆内存和新生代内存环境变量不被应用,,这里先提前copy一份容器内部启动脚本做挂载,如果想自定义内存可以自己调整。

    启动临时rocketmq容器

    docker run -d \
    --privileged=true \
    --name rmqnamesrv \
    apache/rocketmq:5.1.3 sh mqnamesrv
    

    复制容器内的文件到挂载目录中

    [root@mq-126 bin]# docker cp rmqnamesrv:/home/rocketmq/rocketmq-5.1.3/bin/ /data/opt/rocketmq/nameserver/
    [root@mq-126 bin]# ls
    cachedog.sh           mqbroker.numanode0  os.sh
    cleancache.sh         mqbroker.numanode1  play.cmd
    cleancache.v1.sh      mqbroker.numanode2  play.sh
    controller            mqbroker.numanode3  README.md
    dledger               mqcontroller        runbroker.cmd
    docker-entrypoint.sh  mqcontroller.cmd    runbroker.sh
    export.sh             mqnamesrv           runserver.cmd
    mqadmin               mqnamesrv.cmd       runserver.sh
    mqadmin.cmd           mqproxy             setcache.sh
    mqbroker              mqproxy.cmd         startfsrv.sh
    mqbroker.cmd          mqshutdown          tools.cmd
    mqbrokercontainer     mqshutdown.cmd      tools.sh
    

    修改 runserver.sh,把 calculate_heap_sizes 这句注释掉,

    # 注释掉以下这句
    # calculate_heap_sizes
    
    # Dynamically calculate parameters, for reference.
    

    然后停止并删除容器

    docker stop rmqnamesrv && docker rm rmqnamesrv
    
  2. 创建Broker需要挂载的文件夹和文件

    # 创建需要的挂载目录
    mkdir /data/opt/rocketmq/broker/logs -p 
    mkdir /data/opt/rocketmq/broker/data -p 
    mkdir /data/opt/rocketmq/broker/conf -p 
    mkdir /data/opt/rocketmq/broker/bin -p 
    mkdir /data/opt/rocketmq/broker/store -p
    

    给目录赋权限

    # 777 文件所属者、文件所属组和其他人有读取 & 写入 & 执行全部权限。rwxrwxrwx
    chmod 777 -R /data/opt/rocketmq/broker/*
    

    启动临时容器

    docker run -d \
    --name rmqbroker \
    --privileged=true \
    apache/rocketmq:5.1.3 \
    sh mqbroker
    

    拷贝运行文件

    [root@mq-126 bin]# docker cp rmqbroker:/home/rocketmq/rocketmq-5.1.3/bin/ /data/opt/rocketmq/broker/
    Successfully copied 110kB to /data/opt/rocketmq/broker/
    [root@mq-126 bin]# ls
    cachedog.sh           mqbroker.numanode0  os.sh
    cleancache.sh         mqbroker.numanode1  play.cmd
    cleancache.v1.sh      mqbroker.numanode2  play.sh
    controller            mqbroker.numanode3  README.md
    dledger               mqcontroller        runbroker.cmd
    docker-entrypoint.sh  mqcontroller.cmd    runbroker.sh
    export.sh             mqnamesrv           runserver.cmd
    mqadmin               mqnamesrv.cmd       runserver.sh
    mqadmin.cmd           mqproxy             setcache.sh
    mqbroker              mqproxy.cmd         startfsrv.sh
    mqbroker.cmd          mqshutdown          tools.cmd
    mqbrokercontainer     mqshutdown.cmd      tools.sh
    

    修改 runbroker.sh,把 calculate_heap_sizes 这句注释掉,

    # 注释掉以下这句
    # calculate_heap_sizes
    
    # Dynamically calculate parameters, for reference.
    

    拷贝配置文件

    [root@mq-126 conf]# docker cp rmqbroker:/home/rocketmq/rocketmq-5.1.3/conf/ /data/opt/rocketmq/broker/
    Successfully copied 145kB to /data/opt/rocketmq/broker/
    [root@mq-126 conf]# ls
    2m-2s-async  dledger                     rmq-proxy.json
    2m-2s-sync   plain_acl.yml               rmq.proxy.logback.xml
    2m-noslave   rmq.broker.logback.xml      rmq.tools.logback.xml
    broker.conf  rmq.client.logback.xml      tools.yml
    container    rmq.controller.logback.xml
    controller   rmq.namesrv.logback.xml
    

    修改 broker.conf

    # 集群名称
    brokerClusterName = DefaultCluster
    # 节点名称
    brokerName = broker-a
    # broker id节点ID, 0 表示 master, 其他的正整数表示 slave,不能小于0 
    brokerId = 0
    # Broker服务地址	String	内部使用填内网ip,如果是需要给外部使用填公网ip
    brokerIP1 = 10.4.7.125
    # Broker角色
    brokerRole = ASYNC_MASTER
    # 刷盘方式
    flushDiskType = ASYNC_FLUSH
    # 在每天的什么时间删除已经超过文件保留时间的 commit log,默认值04
    deleteWhen = 04
    # 以小时计算的文件保留时间 默认值72小时
    fileReservedTime = 72
    # 是否允许Broker 自动创建Topic,建议线下开启,线上关闭
    autoCreateTopicEnable=true
    # 是否允许Broker自动创建订阅组,建议线下开启,线上关闭
    autoCreateSubscriptionGroup=true
    

    停止并删除临时的broker容器

    docker stop rmqbroker && docker rm rmqbroker
    

3. 准备Docker Compose 文件

/data/opt/rocketmq目录创建docker-compose.yml文件

version: '3.8'
services:
  rmqnamesrv:
    image: apache/rocketmq:5.1.3
    container_name: rmqnamesrv
    ports:
      - 9876:9876
    restart: always
    privileged: true
    volumes:
      - /data/opt/rocketmq/nameserver/logs:/home/rocketmq/logs
      - /data/opt/rocketmq/nameserver/bin/runserver.sh:/home/rocketmq/rocketmq-5.1.3/bin/runserver.sh
    environment:
      - MAX_HEAP_SIZE=256M
      - HEAP_NEWSIZE=128M
    command: ["sh","mqnamesrv"]
  broker:
    image: apache/rocketmq:5.1.3
    container_name: rmqbroker
    ports:
      - 10909:10909
      - 10911:10911
      - 8081:8081
    restart: always
    privileged: true
    volumes:
      - /data/opt/rocketmq/broker/logs:/home/rocketmq/logs
      - /data/opt/rocketmq/broker/store:/home/rocketmq/store
      - /data/opt/rocketmq/broker/conf/broker.conf:/home/rocketmq/broker.conf
      - /data/opt/rocketmq/broker/bin/runbroker.sh:/home/rocketmq/rocketmq-5.1.3/bin/runbroker.sh
    depends_on:
      - 'rmqnamesrv'
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
      - MAX_HEAP_SIZE=512M
      - HEAP_NEWSIZE=256M
    command: ["sh","mqbroker","-c","/home/rocketmq/broker.conf","--enable-proxy"]
  rmqdashboard:
    image: apacherocketmq/rocketmq-dashboard:latest
    container_name: rocketmq-dashboard-latest
    ports:
      - 8080:8080
    restart: always
    privileged: true
    depends_on:
      - 'rmqnamesrv'
    environment:
      - JAVA_OPTS= -Xmx256M -Xms256M -Xmn128M -Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false

使用docker compose 命令启动

[root@mq_125 rocketmq]# vi docker-compose.yml
[root@mq_125 rocketmq]# docker compose up -d
[+] Building 0.0s (0/0)
[+] Running 3/3
 ✔ Container rmqnamesrv                 Started              0.7s
 ✔ Container rocketmq-dashboard-latest  Started              2.6s
 ✔ Container rmqbroker                  Started

4. 发送和消费消息测试

测试代码与linux部署相同文章来源地址https://www.toymoban.com/news/detail-652088.html

到了这里,关于RocketMQ部署 Linux方式和Docker方式的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Docker的安装及其常见中间件的部署

    基于centos7安装docker(Docker要求CentOS系统的内核版本高于3.10 uname -r 查看内核版本) 最好安装7.5以上版本支持k8s (1) 如果之前下载过需要运行命令卸载 (2)安装 Docker-CE 基本环境 (3)设置 docker repo 的 yum 位置 (4)安装 docker,以及 docker-cli (5)启动docker (6)停止docker (7)重启docker (8)查看

    2024年02月19日
    浏览(33)
  • 消息中间件-RocketMQ

            RocketMQ是阿里巴巴开源的消息分布中间件,在阿里内部使用非常更广泛,已经经过了“双11”这种万亿级的应用场景考验。 1.安装         下载地址:http://rocketmq.apache.org/release_notes/release-notes-4.4.0/         下载完成后解压缩安装包到指定目录。 2.配置    

    2024年02月09日
    浏览(41)
  • RocketMQ(消息中间件)

    目录 一、为什么会出现消息中间件? 二、消息中间件是干嘛的? 三、应用解耦 四、流量削峰 五、异步处理 1.串行方式: 2.并行方式: 3.引入消息队列:  六、RocketMQ的架构及概念 Http请求默认采用同步请求方式,基于请求与响应模式,在客户端与服务器进行通讯 时,客户端

    2024年02月10日
    浏览(44)
  • 消息中间件系列 - RocketMQ

    本内容仅用于个人学习笔记,如有侵扰,联系删除 【尚硅谷】RocketMQ教程丨深度掌握MQ消息中间件_哔哩哔哩_bilibili 1 、MQ简介 MQ , Message Queue ,是一种提供 消息队列服务 的中间件,也称为消息中间件,是一套提供了消息生产、存储、消费全过程API的软件系统。消息即数据。

    2024年02月16日
    浏览(67)
  • 【Java中间件】RocketMQ

    Message Queue,是一种提供消息队列服务的中间件。提供了消息生产、存储、消费全过程API的软件系统。 MQ的作用 限流削峰:当用户发送超量请求时,将请求暂存,以便后期慢慢处理。如果不使用MQ暂存直接请求到业务系统中容易引起系统崩溃。 异步解耦:若上游系统和下游系

    2024年02月15日
    浏览(41)
  • 消息队列中间件 MetaQ/RocketMQ

    推荐电子书:云原生架构白皮书 2022版-藏经阁-阿里云开发者社区 (aliyun.com) 简介—— 消息队列中间件 MetaQ/RocketMQ 中间件 MetaQ 是一种基于队列模型的消息中间件,MetaQ 据说最早是受 Kafka 的影响开发的,第一版的名字 \\\"metamorphosis\\\",是奥地利作家卡夫卡的名作——《变形记》。

    2024年02月14日
    浏览(53)
  • 【中间件】通过 docker-compose 快速部署 Kafka 保姆级教程

    Kafka是由Apache基金会开发的分布式流处理平台,采用发布-订阅模式,支持高吞吐量、低延迟的数据传输。主要用于处理实时数据管道、数据存储和数据分析等大数据应用场景。Kafka采用高效的数据压缩算法,可以在集群中存储大量的数据,并通过分区机制来实现数据的高可靠

    2024年02月12日
    浏览(49)
  • 消息中间件之RocketMQ源码分析(十)

    启动命令 nohup ./bin/mqnamesrv -c ./conf/namesrv.conf dev/null 21 通过脚本配置启动基本参数,比如配置文件路径、JVM参数,调用NamesrvStartup.main()方法,解析命令行的参数,将处理好的参数转化为Java实例,传递给NamesrvController实例 加载命令行传递的配置参数,调用controller.initialize()方法初

    2024年02月20日
    浏览(53)
  • 分布式消息中间件RocketMQ的应用

    所有代码同步至GitCode:https://gitcode.net/ruozhuliufeng/test-rocketmq.git 普通消息 消息发送分类 ​ Producer对于消息的发送方式也有多种选择,不同的方式会产生不同的系统效果。 同步发送消息 ​ 同步发送消息是指,Producer发出一条消息后,会在收到MQ返回的ACK之后才发下一条消息。

    2024年02月05日
    浏览(82)
  • Kafka、RabbitMQ、RocketMQ中间件的对比

    消息中间件现在有不少,网上很多文章都对其做过对比,在这我对其做进一步总结与整理。     RocketMQ 淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件,使用Mysql作为消息存储媒介,可完全水平扩容,为了进一步降低成本,我们认为存储部分可以进一步优化,201

    2024年02月05日
    浏览(36)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包