2.10日学习打卡----初学RocketMQ(一)

2.10日学习打卡

对于MQ(Message queue)消息队列的一些解释可以看我原来写的文章 初学RabbitMQ

各大MQ产品比较
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

一.RocketMQ概述

发展历程

在这里插入图片描述

RocketMQ概念术语

  • 生产者和消费者
    生产者负责生产消息,一般由业务系统负责生产消息,消费者即后台系统,它负责消费消息。
    在这里插入图片描述
  • 消息模型(Message Model)
    消息模型主要有队列模型和发布订阅模型,RabbitMQ采用的是队列模型,如下图所示
    在这里插入图片描述
    RocketMQ采用发布订阅模型,模型如图所示:
    在这里插入图片描述
  • 主题(Topic)

在这里插入图片描述
表示一类消息的集合,每个主题包含若干条消息,每条消息只能属于一个主题,是RocketMQ进行消息订阅的基本单位。

  • 代理服务器(Broker Server)

在这里插入图片描述
消息中转角色,负责存储消息、转发消息。

  • 名字服务(Name Server)

名称服务管理代理服务器broker,相当于一个管理机构。

  • 生产者组(Producer Group)
    在这里插入图片描述
    同一类Producer的集合,这类Producer发送同一类消息且发送逻辑一致。

  • 消费者组(Consumer Group)

在这里插入图片描述
同一类Consumer的集合,这类Consumer通常消费同一类消息且消费逻辑一致。

  • 拉取式消费(Pull Consumer)

在这里插入图片描述
Consumer消费的一种类型,应用通常主动调用Consumer的拉消息方法从Broker服务器拉消息、主动权由应用控制。一旦获取了批量消息,应用就会启动消费过程。

  • 推动式消费(Push Consumer)

在这里插入图片描述
Consumer消费的一种类型,该模式下Broker收到数据后会主动推送给消费端,该消费模式一般实时性较高。

  • 普通顺序消息(Normal Ordered Message)
    ![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/9178444faae640769fb8dca7c5633f2b.png在这里插入图片描述
    普通顺序消费模式下,消费者通过同一个消息队列( Topic 分区,称作 Message Queue) 收到的消息是有顺序的,不同消息队列收到的消息则可能是无顺序的。

  • 严格顺序消息(Strictly Ordered Message)
    在这里插入图片描述
    严格顺序消息模式下,消费者收到的所有消息均是有顺序的。

二 . RocketMQ安装与配置

在这里插入图片描述

环境搭建与测试

下载地址:https://rocketmq.apache.org/zh/release-notes/

在这里插入图片描述
选择第二个 binary 安装

  1. 首先使用rz命令 将文件上传到虚拟机
  2. 解压文件 unzip rocketmq-all-5.1.4-bin-release.zip(自己的版本)
  3. 重命名文件夹名字便于修改 mv rocketmq-all-5.1.4-bin-release rocketmq-5.1.4
  4. 移动文件夹到 /usr/local 目录下 mv rocketmq-5.1.4 /usr/local
  5. 修改环境变量
    vim /etc/profile
export JAVA_HOME=/usr/local/jdk-11.0.11/
export PATH=$PATH:$JAVA_HOME/bin
export ROCKETMQ_HOME=/usr/local/rocketmq-5.1.4(自己的版本)
export PATH=$PATH:$ROCKETMQ_HOME/bin
  1. 启动NameServer nohup sh mqnamesrv &
  2. 启动broker nohup sh mqbroker -n localhost:9876

RocketMQ管理命令

mqadmin help 命令名称

  • 启动namesrv和broker

./mqnamesrv #启动nameserver
./mqbroker -n localhost:9876 -c /opt/alibaba-rocketmq/conf/broker.conf #启动broker

  • #启动broker

tail -f ~/logs/rocketmqlogs/namesrv.log
#查看日志
tail -f ~/logs/rocketmqlogs/broker.log
#查看日志

  • 新增topic

mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t topicWarning

  • 查看某个topic的状态

mqadmin topicStatus -n localhost:9876 -t topicWarning

  • 查看所有消费组group

mqadmin consumerProgress -n localhost:9876

  • 查看所有topic

mqadmin topicList -n localhost:9876

  • 删除topic

mqadmin deleteTopic -n localhost:9876 -c DefaultCluster -t topicWarning

  • 关闭namesrv和broker服务

mqshutdown namesrv
mqshutdown broker

如果我的内容对你有帮助,请点赞,评论,收藏。创作不易,大家的支持就是我坚持下去的动力!
在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

无人机遥感技术应用分析,无人机遥感系统测绘技术详解

由于无人机具有机动快速、使用成本低、维护操作简单等技术特点,因此被作为一种理想的飞行平台广泛应用于军事和民用各个领域。尤其是进入二十一世纪以后,许多国家将无人机系统的研究、开发、应用置于优先发展的地位,体积小、重量轻、探测精度高的新型传感器的不断问世,也使无人…

解决挂梯子 无法正常上网 的问题

方法: 打开 控制面板 👉 网络和Internet 👉 Internet选项 👉 连接 👉 局域网设置 👉 代理服务器 👉 取消选项 有问题可参考下图

中科大计网学习记录笔记(九):DNS

前言: 学习视频:中科大郑烇、杨坚全套《计算机网络(自顶向下方法 第7版,James F.Kurose,Keith W.Ross)》课程 该视频是B站非常著名的计网学习视频,但相信很多朋友和我一样在听完前面的部分发现信…

【MySQL】-18 MySQL综合-4(MySQL储存引擎精讲+MySQL数据类型简介+MySQL整数类型+MySQL小数类型)

MySQL储存引擎精讲MySQL数据类型简介MySQL整数类型MySQL小数类型 十一 MySQL存储引擎精讲11.1 什么是存储引擎11.2 MySQL 5.7 支持的存储引擎11.3 如何选择 MySQL 存储引擎11.4 MySQL 默认存储引擎 十二 MySQL数据类型简介12.1 MySQL 常见数据类型1) 整数类型2) 日期/时间类型3…

Python中的正则表达式(一)

在Python中,正则表达式是一种用于匹配和操作字符串的强大工具。正则表达式由一系列字符和特殊字符组成,用于定义搜索模式。 在Python中,我们使用内置的 re 模块来操作正则表达式。要使用正则表达式,我们首先需要导入 re 模块。 下…

1.2 Binance_interface API函数接口总览

Binance_interface API函数接口总览 Github地址PyTed量化交易研究院 1. 现货 SPOT from binance_interface.api import SPOT1.1 账户接口 SPOTAccount from binance_interface.api.spot import SPOTAccount方法解释Pathget_account账户信息/api/v3/accountget_myTrades账户…

Linux rdev命令教程:查询/设置内核映像文件的根设备,RAM磁盘大小或视频模式(附实例详解和注意事项)

Linux rdev命令介绍 rdev是一个Linux命令,它可以用来查询/设置内核映像文件的根设备,RAM磁盘大小或视频模式。不带任何参数的rdev命令将输出当前根文件系统的/etc/mtab文件行。 Linux rdev命令适用的Linux版本 rdev命令在大多数Linux发行版中都可以使…

批量提取word文件中文本框内容的三种方法

一、问题的提出 在日常的办公中,有时需要提取多个word文件中的文字框的内容。有时,文字框的数量比较多,而且处于文档的不同位置,手工提取比较耗时耗力,同时也可能会产生遗漏。 我们也可以通过VBA和Python来解决这个问…

时间函数举例2

#include <stdio.h> #include <time.h> int main() { time_t start,end; int i; starttime(NULL); for(i0;i<300000;i) { printf("\n"); // 返回两个time_t型变量之间的时间间隔 } endtime(NULL); //…

飞天使-linux操作的一些技巧与知识点8-zabbix6.0 容器搭建

文章目录 安装docker安装步骤mysql下载镜像安装zabbix 使用zabbix非host模式创建 测试效果 安装docker 1. 配置官方 yum 源$ sudo yum install -y yum-utils $ sudo yum-config-manager \--add-repo \https://download.docker.com/linux/centos/docker-ce.repo2. 安装 Docker$ …

微服务入门篇:http客户端Feign(远程调用,自定义配置,Feign的性能优化,Feign服务抽取)

目录 1.基于Feign的远程调用1.RestTemplate方式调用存在的问题2.Feign的介绍3.定义和使用Feign客户端 2.自定义配置1.方式一&#xff1a;配置文件方式2.方式二: java代码方式&#xff0c;需要先声明一个Bean: 3.Feign的性能优化1.Feign底层的客户端实现2.连接池配置 4.Feign的最…

Open CASCADE学习|放样

在CAD&#xff08;计算机辅助设计&#xff09;建模中&#xff0c;放样是一种重要的技术&#xff0c;用于将二维图形或设计转化为三维模型。通过放样&#xff0c;设计师可以根据一系列二维剖面和一个或多个引导路径创建出复杂的三维形状。 CAD建模放样的基本步骤如下&#xff1…

MongoDB聚合:$unionWith

$unionWith聚合阶段执行两个集合的合并&#xff0c;将两个集合的管道结果合并到一个结果集传送到下一个阶段。合并后的结果文档的顺序是不确定的。 语法 { $unionWith: { coll: "<collection>", pipeline: [ <stage1>, ... ] } }要包含集合的所有文档不…

Java-jdk,eclipse,tomcat,MySQL,navicat,Chrome浏览器,腾讯云服务器购买,Xshell安装教程

安装视频教程 安装包&#xff1a; 链接&#xff1a;https://pan.baidu.com/s/15IciNZXuZT3sUcyAY-eawg 提取码&#xff1a;ez4r

2024.02.11作业

1.请使用递归实现n! #include <stdio.h> #include <stdlib.h> #include <string.h>int func(int n) {if (n 1){return 1;}return func(n - 1) * n; }int main() {int n 5;printf("%d\n", func(5));return 0; } 2.请使用递归实现0-n的和 #inclu…

【java基础题型】录入3位数,求每一位是?

\t 制表符&#xff0c;用于整到8个格子 Scanner类&#xff0c;导入Scanner包(1),代码里导入Scanner类写录入&#xff0c;调用录入的对象的方法 通用求个位数&#xff0c;%10即可&#xff0c;余数不会小于除数 package java录入3位数;import java.util.Scanner; …

前端架构: 脚手架开发流程中的难点梳理

脚手架的开发流程 1 &#xff09;开发流程 创建 npm 项目创建脚手架入口文件&#xff0c;最上方添加&#xff1a; #!/usr/bin/env node 配置 package.json, 添加 bin 属性编写脚手架代码将脚手架发布到 npm 2 &#xff09;使用流程 安装脚手架 npm install -g your-own-cli …

Rust猜数字游戏

Rust进阶&#xff1a;猜数字游戏 Rust是一门现代的系统级编程语言&#xff0c;注重内存安全、并发性能以及表达力。在这篇博客中&#xff0c;我们将深入介绍一个更加复杂的猜数字游戏代码&#xff0c;展示Rust语言的一些高级特性。 代码示例 以下是一个升级版的Rust猜数字游…

【蓝桥杯Python】试题 算法训练 比较

资源限制 内存限制&#xff1a;256.0MB C/C时间限制&#xff1a;1.0s Java时间限制&#xff1a;3.0s Python时间限制&#xff1a;5.0s 问题描述 给出一个n长的数列&#xff0c;再进行m次询问&#xff0c;每次询问询问两个区间[L1,R1]&#xff0c;[L2,R2]&#xff0c;   …

MySQL分组优化

分组优化 在使用group by进行分组时&#xff0c;实际上也需要进行排序操作&#xff0c;与order by相比&#xff0c;group by主要是多了排序之后的分组操作 group by的实现有三种方式 使用松散索引扫描实现group by 使用紧凑索引扫描实现group by 使用松散索引扫描实现group by …