当前位置: 首页 > news >正文

centos7 install rocketmq 宿主机快速搭建RocketMQ单机开发环境_centos7 单机部署rocketmq命令

2214 Jps
2071 BrokerStartup
1947 NamesrvStartup


### 第四步:发送消息测试消费着启动

export NAMESRV_ADDR=localhost:9876
./tools.sh org.apache.rocketmq.example.quickstart.Consumer


发送测试消息

export NAMESRV_ADDR=localhost:9876
./tools.sh org.apache.rocketmq.example.quickstart.Producer


### 第五步:docker控制台搭建rocketmq-dashboard(可视化控制台)

docker run -it -p 8060:8080 -e NAMESRV_ADDR=<主机ip>:9876 --rm apacherocketmq/rocketmq-dashboard /bin/bash


1. -v /apps/rocketmq-dashboard/data:/tmp/rocketmq-console/data 参数用于将主机的 /apps/rocketmq-dashboard/data 目录映射到容器的 /tmp/rocketmq-console/data  目录,这样可以持久化保存 RocketMQ Dashboard 的数据。
2. -e NAMESRV\_ADDR=[你的主机IP]:9876 参数用于设置环境变量 NAMESRV\_ADDR,指定 RocketMQ 的 Namesrv 地址。可视化控制台 http://localhost:8060/#/cluster [rocketmq-dashboard(可视化控制台)]( )  ![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/bba1559ae0884ea19d5be619d73a8855.png)### 第六步:rocketmq-client-go 测试延迟消息延迟5秒代码测试示例  ![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/b4154d3116db4c3c929540a7d99f9344.gif#pic_center)consumer.go

package main

import (
“context”
“fmt”
“github.com/apache/rocketmq-client-go/v2”
“github.com/apache/rocketmq-client-go/v2/consumer”
“github.com/apache/rocketmq-client-go/v2/primitive”
“os”
“time”
)

func main() {
// 设置推送消费者
c, _ := rocketmq.NewPushConsumer(
//消费组
consumer.WithGroupName(“testGroup”),
// namesrv地址
consumer.WithNameServer([]string{“127.0.0.1:9876”}),
)
// 必须先在 开始前
err := c.Subscribe(“Topic-test”, consumer.MessageSelector{}, func(ctx context.Context, ext …*primitive.MessageExt) (consumer.ConsumeResult, error) {
for i := range ext {
// 获取消息正文
body := ext[i].Body
fmt.Printf(“获取到值:%s \n”, body)
}
return consumer.ConsumeSuccess, nil
})
if err != nil {
fmt.Println(err.Error())
}
err = c.Start()
if err != nil {
fmt.Println(err.Error())
os.Exit(-1)
}
time.Sleep(time.Hour)
err = c.Shutdown()
if err != nil {
fmt.Printf(“shutdown Consumer error:%s”, err.Error())
}
}

export ROCKETMQ_GO_LOG_LEVEL=warn
go run consumer.go


producer\_delay.go

func main() {
p, _ := rocketmq.NewProducer(
// 设置 nameSrvAddr
// nameSrvAddr 是 Topic 路由注册中心
producer.WithNameServer([]string{“0.0.0.0:9876”}),
// 指定发送失败时的重试时间
producer.WithRetry(3),
// 设置 Group
producer.WithGroupName(“testGroup”),
)
// 开始连接
err := p.Start()
if err != nil {
fmt.Printf(“start producer error: %s”, err.Error())
os.Exit(2)
}

// 设置节点名称
topic := "Topic-test"
// 循环发送信息 (同步发送)
for i := 0; i < 10; i++ {msg := &primitive.Message{Topic: topic,Body:  []byte("RocketMQ Go producer\_delay.go [" + strconv.Itoa(i) + "] " + time.Now().Format("2006-01-02 15:04:05")),}time.Sleep(time.Second)// WithDelayTimeLevel set message delay time to consume.// reference delay level definition: 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h// delay level starts from 1. for example, if we set param level=1, then the delay time is 1s.// 设置消息的延时级别为 2,对应 RocketMQ 配置中的延时时间 5smsg.WithDelayTimeLevel(2)// 发送信息res, err := p.SendSync(context.Background(), msg)if err != nil {fmt.Printf("发送失败!:%s\n", err)} else {fmt.Printf("发送成功 : result=%s\n", res.String())}
}
// 关闭生产者
err = p.Shutdown()
if err != nil {fmt.Printf("shutdown producer error:%s", err.Error())
}

}

相关文章:

centos7 install rocketmq 宿主机快速搭建RocketMQ单机开发环境_centos7 单机部署rocketmq命令

2214 Jps 2071 BrokerStartup 1947 NamesrvStartup ### 第四步&#xff1a;发送消息测试消费着启动export NAMESRV_ADDRlocalhost:9876 ./tools.sh org.apache.rocketmq.example.quickstart.Consumer 发送测试消息export NAMESRV_ADDRlocalhost:9876 ./tools.sh org.apache.roc…...

2024高教社杯全国大学生数学建模竞赛(A题)深度剖析 _ 建模完整过程+详细思路+代码全解析

问题1解答过程 1.1 螺线运动的基本几何模型 板凳龙的舞动路径为等距螺线。螺线是极坐标中一类常见曲线&#xff0c;其特点是半径随角度线性增加。我们可以用以下极坐标方程描述这条螺线&#xff1a; r ( θ ) p 2 π θ r(\theta) \frac{p}{2\pi} \theta r(θ)2πp​θ 其…...

What is Approximation Ratio?

Approximation Ratio 近似比率是用来衡量一个算法找到的近似解与最优解之间的差距的一个量化指标. 假设有一个优化问题&#xff0c;其最优解的值是OPT&#xff0c;用时间T&#xff0c;而我们的算法得到的解的值是ALG,用时间t。如果算法有一个2的近似比率&#xff0c;那么我们…...

探索Unity与C#的无限潜能:从新手到高手的编程之旅

在数字创意与技术创新交织的今天&#xff0c;Unity游戏引擎凭借其强大的跨平台能力和灵活的编程接口&#xff0c;成为了无数开发者心中的首选。而C#&#xff0c;作为Unity的官方脚本语言&#xff0c;更是以其面向对象的特性和丰富的库支持&#xff0c;为游戏开发注入了无限可能…...

初始MYSQL数据库(2)——创建、查询、更新、删除数据表的相关操作

找往期文章包括但不限于本期文章中不懂的知识点&#xff1a; 个人主页&#xff1a;我要学编程(ಥ_ಥ)-CSDN博客 所属专栏&#xff1a; MYSQL 前面我们学习了创建、删除数据库以及创建、查看、删除数据表的相关操作。 我们知道数据库中所存储的数据其实就是数据表中一条一条的记…...

OpenCV直方图计算

#include <opencv2/opencv.hpp> #include <vector>using namespace cv; using namespace std;int main() {cout << "直方图calcHist" << endl;Mat src imread("left.png", IMREAD_GRAYSCALE);if (src.empty()){cout << &qu…...

多线程篇(并发相关类- 原子操作类)(持续更新迭代)

目录 前言 一、原子变量操作类&#xff08;AtomicLong为例&#xff09; 1. 前言 2. 实例 二、JDK 8新增的原子操作类LongAdder 三、LongAccumulator类原理探究 前言 JUC包提供了一系列的原子性操作类&#xff0c;这些类都是使用非阻塞算法CAS实现的&#xff0c;相比使用…...

数学建模常用工具总结

数学建模常用工具总结 绘图篇pythonMATLABLIVEGAP CHARTSApache EChartsBioLadderHiplot Pro 生物医学可视化平台Graph EditorRAWGraphs 2.0ExcalidrawPPT绘图 配色篇Color SpaceAdobe Color 素材篇手绘素材插画网iconfont-阿里巴巴矢量图标库下面四个都是实物风格的素材&#…...

【Redis】为什么选择 Redis 做缓存?

近期文章&#xff1a; 【Redis】Redis 底层的数据结构&#xff08;结合源码&#xff09; 【MySQL】索引底层的数据结构 BTree 在系统开发中&#xff0c;我们经常会使用 Redis 作为缓存系统&#xff0c;但你知道为什么要使用缓存吗&#xff1f;为什么是使用 Redis 作为缓存呢&…...

Flutter 开发常用第三方库总结

Flutter 开发常用第三方库总结 常用库 常用库 屏幕适配flutter_screenutil加载 svg flutter_svg状态管理 flutter_bloc&#xff08;bloc、equatable&#xff09;、provider视频播放器chewie图片缓存cached_network_image网络请求 dio设备信息查询device_info_plus文件路径 pat…...

OpenCV中的颜色映射函数applyColorMap的使用

操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 算法描述 OpenCV 中应用类似于 GNU Octave 或 MATLAB 中的颜色映射&#xff0c;虽然 OpenCV 中的颜色映射类型与 GNU Octave 或 MATLAB 中的颜色映射类型名…...

Ubuntu22.04安装colmap

首先上这里查看自己电脑GPU的CMAKE_CUDA_ARCHITECTURES 终端输入以下内容安装预先的前置依赖 sudo apt-get install \git cmake ninja-build build-essential \libboost-program-options-dev libboost-filesystem-dev \libboost-graph-dev libboost-system-dev libboost-tes…...

认识GO语言中的nil,零值与空结构体

go语言的初学者&#xff0c;特别是java开发者新学习go语言&#xff0c;对于一些和java类似但是又有差异的概念很容易混淆&#xff0c;比如说go中的零值&#xff0c;nil 和 空结构体。本文就来详细探讨一下go中这些特殊概念的含义和实际场景中的应用&#xff1a; 零值 零值&…...

Node.js sqlite3:Statement对象详解

在Node.js的sqlite3库中&#xff0c;Statement对象是一个非常重要的概念。它代表了一个预编译的SQL语句&#xff0c;可以多次执行以提高性能。通过使用Statement对象&#xff0c;你可以避免重复解析和编译SQL语句的开销&#xff0c;特别是在需要频繁执行相同SQL语句的情况下。本…...

ELK学习笔记——如何给Kibana新增用户和角色

Kibana新增用户和角色 首先用超管账号登录上Kibana&#xff0c;按照下面步骤操作 1、创建角色 按图操作 2、创建用户 按图操作 3、给用户分配角色 至此&#xff0c;角色和用户绑定成功&#xff1b; 最后&#xff0c;可以退出管理员账号&#xff0c;登录这个新…...

Minikube Install Kubernetes v1.18.1

文章目录 简介安装工具配置代理运行集群检查集群加入rancher 简介 模拟客户环境&#xff0c;测试 kubernetes v1.18.x 是否可以被 rancher v2.9.1 纳管。 安装工具 docker 安装Install and Set Up kubectl on Linux 安装 minikube 配置代理 docker proxylinux proxy 运行…...

重修设计模式-创建型-工厂模式

重修设计模式-创建型-工厂模式 一、概述 工厂模式&#xff08;Factory Pattern&#xff09;是设计模式中非常基础且常用的一种模式&#xff0c;主要目的是通过封装对象的创建过程&#xff0c;从而实现代码的解耦和灵活性的提升。 工厂模式的核心思想 封装对象的创建&#x…...

使用Cskin时候 遇到按钮有默认阴影问题解决

使用Cskin时候 遇到按钮有默认阴影 设置 DrawType 属性就可以了...

121.rk3399 uboot(2017.09) 源码分析1(2024-09-05)

参考源码 : uboot&#xff08;2017.09&#xff09; 硬件平台&#xff1a;rk3399 辅助工具&#xff1a;linux虚拟机&#xff0c;sourceinsight4&#xff0c;文件浏览器&#xff08;可以使用samba访问&#xff09;&#xff0c;ultraeidt(查看bin文件比较方便) 说明&#xff1a…...

【图论】虚树 - 模板总结

适用于解决一棵树中只需要用到少部分点的时候&#xff0c;将需要用到的点提出来单独建一棵树 /********************* 虚树 *********************/ struct edge {int to, next;int val; };struct Virtual_Tree {int n; // 点数int dfn[N]; // dfs序int dep[N]; // 深度int fa…...

告别重复造轮子:用快马平台生成mpu6050优化算法库,开发效率提升数倍

告别重复造轮子&#xff1a;用快马平台生成mpu6050优化算法库&#xff0c;开发效率提升数倍 在嵌入式开发中&#xff0c;MPU6050这款六轴传感器几乎成了运动控制和姿态检测的标配。但每次新项目都要从头写驱动、调滤波算法、实现姿态解算&#xff0c;这种重复劳动实在太低效了…...

Kiro IDE + Amazon Bedrock AgentCore 实战:规范驱动开发 Multi-Agent 金融逾期处理系统,从需求到云上部署只要几小时

Kiro IDE Amazon Bedrock AgentCore 实战&#xff1a;规范驱动开发 Multi-Agent 金融逾期处理系统&#xff0c;从需求到云上部署只要几小时 上周接了个活&#xff1a;把一个金融逾期处理流程用 AI Agent 跑起来。听着不难对吧&#xff1f;五个 Agent 协同干活&#xff0c;从逾…...

别再只当CANopen网关用!EL6751的‘直通CAN’模式,让你像用CAN盒一样调试非标设备

EL6751的直通CAN模式&#xff1a;解锁非标设备调试新姿势 当你的工控柜里躺着几台国产非标设备&#xff0c;厂商只提供了CAN盒调试软件&#xff0c;而手边只有倍福PLC时&#xff0c;那种抓狂的感觉每个自动化工程师都懂。别急着下单采购USBCAN工具&#xff0c;你需要的可能只是…...

KK-HF_Patch技术解析:游戏增强补丁的架构设计与实践方法

KK-HF_Patch技术解析&#xff1a;游戏增强补丁的架构设计与实践方法 【免费下载链接】KK-HF_Patch Automatically translate, uncensor and update Koikatu! and Koikatsu Party! 项目地址: https://gitcode.com/gh_mirrors/kk/KK-HF_Patch 核心价值&#xff1a;重新定义…...

别再用Keil MDK-ARM了?手把手教你用VSCode+GCC搭建STM32F103C8T6开发环境(附标准库模板)

逃离Keil&#xff1a;用VSCodeGCC打造高效STM32开发环境 在嵌入式开发领域&#xff0c;Keil MDK-ARM长期以来都是STM32开发的主流选择。但近年来&#xff0c;越来越多的开发者开始寻求更轻量、更现代化的替代方案。如果你也对Keil的笨重界面、高昂授权费用和有限的定制能力感到…...

vlan练习

实验要求配置路由器IP及接口arp协议配置IP池和dhcp配置交换机1配置交换机2配置交换机3结果...

作业3.7

10.import math# 输入三条边a float(input("请输入三角形的边A&#xff1a;"))b float(input("请输入三角形的边B&#xff1a;"))c float(input("请输入三角形的边C&#xff1a;"))# 判断是否能构成三角形if a > 0 and b > 0 and c >…...

G-Helper完整指南:华硕笔记本的终极轻量级控制工具

G-Helper完整指南&#xff1a;华硕笔记本的终极轻量级控制工具 【免费下载链接】g-helper Lightweight, open-source control tool for ASUS laptops and ROG Ally. Manage performance modes, fans, GPU, battery, and RGB lighting across Zephyrus, Flow, TUF, Strix, Scar,…...

开发者利器:OpenClaw+千问3.5-9B自动生成单元测试

开发者利器&#xff1a;OpenClaw千问3.5-9B自动生成单元测试 1. 为什么需要AI生成单元测试 作为一名长期奋战在一线的开发者&#xff0c;我深知单元测试的重要性——它不仅是代码质量的守护者&#xff0c;更是重构时的安全网。但现实情况是&#xff0c;在紧张的开发周期中&am…...

Pixel Couplet Gen一文详解:Retro Game UI与LLM春联生成融合方案

Pixel Couplet Gen一文详解&#xff1a;Retro Game UI与LLM春联生成融合方案 1. 项目概览 Pixel Couplet Gen是一款将传统春联文化与现代AI技术相结合的创新应用。通过ModelScope大模型驱动&#xff0c;我们打造了一个充满怀旧游戏风格的春联生成器&#xff0c;让用户在数字世…...