Windows单机部署RocketMQ5.X并与SpringBoot集成

news2024/11/28 2:29:48

RocketMQ 5.X下载

《RocketMQ 5.X下载》
在这里插入图片描述
下载后，解压缩

修改初始内存

修改runserver.cmd（Linux则为runserver.sh）

将下面的-Xms2g -Xmx2g -Xmn1g调小

if %JAVA_MAJOR_VERSION% lss 17 (
   set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
   set "JAVA_OPT=%JAVA_OPT% -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSParallelRemarkEnabled -XX:SoftRefLRUPolicyMSPerMB=0 -XX:+CMSClassUnloadingEnabled -XX:SurvivorRatio=8 -XX:-UseParNewGC"
   set "JAVA_OPT=%JAVA_OPT% -verbose:gc -Xloggc:"%USERPROFILE%\rmq_srv_gc.log" -XX:+PrintGCDetails -XX:+PrintGCDateStamps"
   set "JAVA_OPT=%JAVA_OPT% -XX:-OmitStackTraceInFastThrow"
   set "JAVA_OPT=%JAVA_OPT% -XX:-UseLargePages"
   set "JAVA_OPT=%JAVA_OPT% %JAVA_OPT_EXT% -cp "%CLASSPATH%""
) else (
   set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
   rem set "JAVA_OPT=%JAVA_OPT% -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSParallelRemarkEnabled -XX:SoftRefLRUPolicyMSPerMB=0 -XX:+CMSClassUnloadingEnabled -XX:SurvivorRatio=8 -XX:-UseParNewGC"
   rem set "JAVA_OPT=%JAVA_OPT% -verbose:gc -Xloggc:"%USERPROFILE%\rmq_srv_gc.log" -XX:+PrintGCDetails -XX:+PrintGCDateStamps"
   set "JAVA_OPT=%JAVA_OPT% -XX:-OmitStackTraceInFastThrow"
   set "JAVA_OPT=%JAVA_OPT% -XX:-UseLargePages"
   set "JAVA_OPT=%JAVA_OPT% %JAVA_OPT_EXT% -cp "%CLASSPATH%""
)

修改runbroker.cmd(Linux则为runbroker.sh)

将下面的-Xms2g -Xmx2g调小

if %JAVA_MAJOR_VERSION% lss 17 (
   set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g"
   set "JAVA_OPT=%JAVA_OPT% -XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -XX:SurvivorRatio=8"
   set "JAVA_OPT=%JAVA_OPT% -verbose:gc -Xloggc:%USERPROFILE%\mq_gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy"
   set "JAVA_OPT=%JAVA_OPT% -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m"
   set "JAVA_OPT=%JAVA_OPT% -XX:-OmitStackTraceInFastThrow"
   set "JAVA_OPT=%JAVA_OPT% -XX:+AlwaysPreTouch"
   set "JAVA_OPT=%JAVA_OPT% -XX:MaxDirectMemorySize=15g"
   set "JAVA_OPT=%JAVA_OPT% -XX:-UseLargePages -XX:-UseBiasedLocking"
   set "JAVA_OPT=%JAVA_OPT% %JAVA_OPT_EXT% -cp %CLASSPATH%"
) else (
   set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g"
   set "JAVA_OPT=%JAVA_OPT% -XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -XX:SurvivorRatio=8"
   rem set "JAVA_OPT=%JAVA_OPT% -verbose:gc -Xloggc:%USERPROFILE%\mq_gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy"
   rem set "JAVA_OPT=%JAVA_OPT% -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m"
   set "JAVA_OPT=%JAVA_OPT% -XX:-OmitStackTraceInFastThrow"
   set "JAVA_OPT=%JAVA_OPT% -XX:+AlwaysPreTouch"
   set "JAVA_OPT=%JAVA_OPT% -XX:MaxDirectMemorySize=15g"
   set "JAVA_OPT=%JAVA_OPT% -XX:-UseLargePages -XX:-UseBiasedLocking"
   set "JAVA_OPT=%JAVA_OPT% %JAVA_OPT_EXT% -cp "%CLASSPATH%""
)

修改broker.conf

追加以下内容

# 设置NameServer地址和端口
namesrvAddr = 127.0.0.1:9876

# 是否启动自动创建主题，如果自动创建主题被启用，broker会自动创建topic，clusterTopic可以被非管理员用户创建
autoCreateTopicEnable = true

# 是否启动自动创建订阅组，如果启动自动创建订阅组，broker会自动创建订阅组
autoCreateSubscriptionGroup = true

创建Windows启动脚本

RocketMQ_start.bat

@echo off
echo 如果JAVA_HOME和RocketMQ不一致，则可以像下面这样在脚本里面设置 RocketMQ 可以运行的JDK版本
#set JAVA_HOME=C:/Users/X/.jdks/corretto-1.8.0_402
echo 设置 RocketMQ 的bin目录
set rocketmqLocation=D:\softwareWork\rocketmq-all-5.2.0-bin-release\bin\

echo 设置 broker 引用的配置文件
start /min cmd /k %rocketmqLocation%mqbroker.cmd -c ../conf/broker.conf
start /min cmd /k %rocketmqLocation%mqnamesrv.cmd

与SpringBoot集成

pom.xml引入rocketmq

		<!-- RocketMQ -->
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.2.1</version>
        </dependency>

application.yml配置rocketmq 服务地址

# RocketMQ Config
rocketmq:
  name-server: 127.0.0.1:9876

创建MqProducer.java消息生产者

一般情况下生产者和消费者是2个不同的服务，这里只是演示demo，因此不做区分

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Service;

/**
 * 消息生产者（一般情况，生产者和消费者不在同一个项目）
 * 创建日期：2024-05-11
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class MqProducer {
    private final RocketMQTemplate rocketMQTemplate;

    /**
     * 发送消息
     * @param topic 消息主题
     * @param message 消息内容
     */
    public void sendMessage(String topic, String message) {
        rocketMQTemplate.convertAndSend(topic, message);
    }

}

创建MqConsumer.java消息消费者

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

/**
 * 消息消费者（一般情况，生产者和消费者不在同一个项目）
 * 创建日期：2024-05-11
 */
@Slf4j
@Service
@RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-consumer_group")
public class MqConsumer implements RocketMQListener<String> {

    /**
     * 消费对应 topic 主题的消息
     * @param message 生产者发送过来的消息
     */
    @Override
    public void onMessage(String message) {
        // 处理接收到的消息
        log.info("接收到topic = my-topic的消息，内容为: {}", message);
    }

}

创建RocketMqController.java发生消息控制类

import lombok.RequiredArgsConstructor;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * 创建日期：2024-05-11
 */
@RestController
@RequiredArgsConstructor
public class RocketMqController {
    private final MqProducer mqProducer;

    /**
     * 发送消息
     * @param topic 消息主题
     * @param message 消息内容
     */
    @GetMapping("send")
    public void send(@RequestParam(name = "topic", required = false) String topic, @RequestParam(name = "message") String message) {
        if (!StringUtils.hasText(topic)){
            topic = "my-topic";
        }
        mqProducer.sendMessage(topic, message);
    }

}

启动项目，访问：localhost:8080/send?message=‘haha’
生成者会发生一条topic = "my-topic"主题的消息到RocketMQ，
消费者会消费topic = "my-topic"主题的一条消息，上面的代码就只是简单的把消息输出到控制台，因此控制台会输出:haha

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1668588.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Apache反代理Tomcat项目，分离应用服务器和WEB服务器

Apache反代理Tomcat项目，分离应用服务器和WEB服务器

项目的原理是使用单独的机器做应用服务器&#xff0c;再用单独的机器做WEB服务器&#xff0c;从网络需要访问我们的应用的话&#xff0c;就会先经过我们的WEB服务器&#xff0c;再到达应用程序&#xff0c;这样子的好处是我们可以保护应用程序的机器位置&#xff0c;同时还可以…
阅读更多...
长安汽车：基于云器 Lakehouse 的车联网大数据平台建设

长安汽车：基于云器 Lakehouse 的车联网大数据平台建设

近年来随着智能汽车行业的迅速发展&#xff0c;数据也在呈爆炸式增长。长安大数据平台承接了长安在生产上大部分流量应用及日常生产业务应用。本文将分享长安汽车在车联网场景下大数据平台建设面临的一些挑战和具体落地的实践。 主要内容如下&#xff1a; 1. 背景介绍 2. 长…
阅读更多...
渲染农场多少钱一个小时？

渲染农场多少钱一个小时？

​很多第一次准备使用渲染农场的小伙伴不知道渲染农场多少钱一个小时&#xff0c;今天就给大家介绍一下渲染农场多少钱一小时。 现在渲染农场基本都有CPU渲染和GPU渲染&#xff0c;各渲染农场的服务器配置不同&#xff0c;收费也各不相同&#xff0c;不过都是按渲染时长收费&…
阅读更多...
C语言学习（八）typedef 虚拟内存 malloc/free

C语言学习（八）typedef 虚拟内存 malloc/free

目录 一、typedef 类型重定义&#xff08;一&#xff09;使用&#xff08;二&#xff09;define和typedef的区别1. 编译处理的阶段不同2. 功能不同 二、虚拟内存&#xff08;一&#xff09;虚拟内存分布&#xff08;二&#xff09;内存分布1. 静态分配2. 动态分配 三、malloc/f…
阅读更多...
如何使用canvas在图片上进行标注，以下代码不起作用，着实被坑到了（文末附完整代码）

如何使用canvas在图片上进行标注，以下代码不起作用，着实被坑到了（文末附完整代码）

今天发现一个有意思的问题&#xff1a; 如何使用canvas在图片上进行如下的标注&#xff0c;以下代码不起作用,如何修改 原始代码如下&#xff1a; <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name&quo…
阅读更多...
理解进程的基本概念

理解进程的基本概念

1. 什么是进程 进程&#xff0c;即执行中的程序 进程 程序执行 在计算机中&#xff0c;每一个运行的exe程序&#xff0c;就是一个进程 2.为什么会有进程 早期&#xff0c;操作系统只有一个程序&#xff0c;这样效率是很低的。为了提高CPU的利用率&#xff0c;人们将多个程…
阅读更多...
时间复杂度的简单讲解

时间复杂度的简单讲解

小伙伴们大家好&#xff0c;我们又见面了&#xff0c;这次我们直接进入正题 时间复杂度的概念 时间复杂度的定义&#xff1a;在计算机科学中&#xff0c; 算法的时间复杂度是一个函数 &#xff0c;它定量描述了该算法的运行时间。一 个算法执行所耗费的时间&#xff0c;从理论…
阅读更多...
Hadoop-未授权访问-内置配合命令执行RCE

Hadoop-未授权访问-内置配合命令执行RCE

一、Hadoop常见端口及配置文件 Hadoop中有多种端口&#xff0c;这些端口用于不同的服务和通信。以下是Hadoop中常见的端口以及它们的用途&#xff1a; NameNode Web界面端口 (默认: 9870)NameNode 对客户端服务端口 (默认: 8020)Secondary NameNode Web界面端口 (默认: 9868)…
阅读更多...
每日OJ题_贪心算法四⑤_力扣354. 俄罗斯套娃信封问题

每日OJ题_贪心算法四⑤_力扣354. 俄罗斯套娃信封问题

目录 力扣354. 俄罗斯套娃信封问题 解析代码1_动态规划&#xff08;超时&#xff09; 解析代码2_重写排序贪心二分 力扣354. 俄罗斯套娃信封问题 354. 俄罗斯套娃信封问题 难度 困难 给你一个二维整数数组 envelopes &#xff0c;其中 envelopes[i] [wi, hi] &#xff0…
阅读更多...
物联网杀虫灯—新型的环保杀虫设备

物联网杀虫灯—新型的环保杀虫设备

型号推荐&#xff1a;云境天合TH-FD2S】物联网杀虫灯是一种新型环保杀虫设备&#xff0c;其中风吸式太阳能杀虫灯作为其一种特殊类型&#xff0c;展现了独特的工作原理和优势。 风吸式太阳能杀虫灯以太阳能电池板为电源&#xff0c;白天储存电源&#xff0c;晚上为杀虫灯提供电…
阅读更多...
资产公物仓管理系统|实现国有资产智能化管理

资产公物仓管理系统|实现国有资产智能化管理

1、项目背景 资产公物仓管理系统&#xff08;智仓库DW-S201&#xff09;是一套成熟系统&#xff0c;依托互3D技术、云计算、大数据、RFID技术、数据库技术、AI、视频分析技术对RFID智能仓库进行统一管理、分析的信息化、智能化、规范化的系统。 项目设计原则 方案对公物仓资…
阅读更多...
Java 守护线程 ( Daemon Thread )详解

Java 守护线程 ( Daemon Thread )详解

在Java中&#xff0c;线程分为两类&#xff1a;用户线程(User Thread)和守护线程(Daemon Thread)。守护线程是后台线程&#xff0c;主要服务于用户线程&#xff0c;当所有的用户线程结束时&#xff0c;守护线程也会自动结束&#xff0c;JVM会随之退出。守护线程的一个典型例子是…
阅读更多...
docker（四）：数据卷

docker（四）：数据卷

数据卷 卷的设计目的就是数据的持久化&#xff0c;完全独立于容器的生存周期&#xff0c;因此Docker不会在容器删除时删除其挂载的数据卷。 1、docker run docker run -it --privilegedtrue -v /宿主机绝对路径目录:/容器内目录 镜像名2、挂载注意事项 --privilegedtru…
阅读更多...
贪吃蛇（c实现）

贪吃蛇（c实现）

目录 游戏说明&#xff1a; 第一个是又是封面&#xff0c;第二个为提示信息&#xff0c;第三个是游戏运行界面 游戏效果展示&#xff1a; 游戏代码展示&#xff1a; snack.c test.c snack.h 控制台程序的准备&#xff1a; 控制台程序名字修改&#xff1a; 参考&#xff1a…
阅读更多...
【考研数学】汤家凤“免单“数学题被吐槽‘太难’，老汤回应「怎么还有脸笑」，网友：这些题有毒！

【考研数学】汤家凤“免单“数学题被吐槽‘太难’，老汤回应「怎么还有脸笑」，网友：这些题有毒！

我看了汤家凤老师出的几道题&#xff0c;实际上对于考研的同学来说&#xff0c;确实是送分题 第一个是三角函数变换中的万能公式&#xff1b;第二个e^x的泰勒展开公式&#xff1b;第三个是第一类重要极限。只要复习过&#xff0c;那基本上都能正常做出来。 至于汤家凤老师说「…
阅读更多...
C#中数组与列表，集合等的联系

C#中数组与列表，集合等的联系

C#中&#xff0c;所有数组都自动继承于System.Array这个抽象类&#xff0c;数组都为引用类型&#xff0c; 所有对数组的更新都会导致源数组的元素值的篡改。 而所有集合的根都来自可枚举接口IEnumerable 数组有三种样式&#xff1a; 数组的Rank&#xff08;秩&#xff09;属…
阅读更多...
纯血鸿蒙APP实战开发——Grid和List内拖拽交换子组件位置

纯血鸿蒙APP实战开发——Grid和List内拖拽交换子组件位置

Grid和List内拖拽交换子组件位置 介绍 本示例分别通过onItemDrop()和onDrop()回调&#xff0c;实现子组件在Grid和List中的子组件位置交换。 效果图预览 使用说明&#xff1a; 拖拽Grid中子组件&#xff0c;到目标Grid子组件位置&#xff0c;进行两者位置互换。拖拽List中子…
阅读更多...
【数据结构】环状链表OJ题

【数据结构】环状链表OJ题

✨✨✨专栏&#xff1a;数据结构 &#x1f9d1;‍&#x1f393;个人主页&#xff1a;SWsunlight 一、OJ 环形链表&#xff1a; 快慢指针即可解决问题: 2情况&#xff1a; 快指针走到结尾&#xff08;不是环&#xff09;快指针和尾指针相遇&#xff08;是环的&#xff09; …
阅读更多...
macos使用yarn创建vite时出现Usage Error: The nearest package directory问题

macos使用yarn创建vite时出现Usage Error: The nearest package directory问题

步骤是macos上使用了yarn create vite在window上是直接可以使用了yarn但是在macos上就出现报错 我们仔细看&#xff0c;它说的If /Users/chentianyu isnt intended to be a project, remove any yarn.lock and/or package.json file there.说是要我们清除yarn.lock和package.js…
阅读更多...
OGG几何内核-网格化的改进

OGG几何内核-网格化的改进

OGG社区于4月19日发布了OGG 1.0 preview版本。相对于OCCT 7.7.0有很多改进&#xff0c;目前在持续研究中。最近测试了一下网格化&#xff0c;确实有很好的改进。对比展示如下&#xff1a; 几何内核&#xff1a; OGG 1.0 preview 几何内核&#xff1a;OCCT 7.7.0 采用OCCT几何内…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023