# 全面解剖 消息中间件 RocketMQ-(2)

全面解剖 消息中间件 RocketMQ-(2)

一、RocketMQ – RocketMQ 各角色介绍

1、RocketMQ 各角色介绍

  • Producer : 消息的发送者; 举例:发信者。
  • Consumer : 消息接收者; 举例:收信者。
  • Broker : 暂存和传输消息; 举例:邮局。
  • NameServer : 管理 Broker; 举例:各个邮局的管理机构
  • Topic : 区分消息的种类; 一个发送者可以发送消息给一个或者多个 Topic; 一个消息的接收者可以订阅一个或者多个 Topic 消息。
  • Message Queue : 相当于是 Topic 的分区;用于并行发送和接收消息。

2、RocketMQ 各角色 示例图:

在这里插入图片描述

二、RocketMQ – RocketMQ 集群特点

1、NameServer 是一个几乎无状态节点,可集群部署,节点之间无任何信息同步。

2、Broker 部署相对复杂,Broker 分为 Master 与 Slave,一个 Master 可以对应多个 Slave,但是一个 Slave 只能对应一个 Master。Master 与 Slave 的对应关系通过指定相同的 BrokerName,不同的 Brokerld 来定义,Brokerld 为 0 表示 Master,非 0 表示 Slave。

3、Master 也可以部署多个。每个 Broker 与 NameServer 集群中的所有节点建立长连接,定时注册 Topic 信息到所有 NameServer。

4、Producer 与 NameServer 集群中的其中一个节点(随机选择)建立长连接,定期从 NameServer 取 Topic 路由信息,并向提供 Topic 服务的 Master 建立长连接,且定时向 Master 发送心跳。Producer 完全无状态,可集群部署。

5、Consumer 与 NameServer 集群中的其中一个节点(随机选择)建立长连接,定期从 NameServer 取 Topic 路由信息,并向提供 Topic 服务的 Master、Slave 建立长连接,且定时向 Master、Slave 发送心跳。Consumer 既可以从 Master 订阅消息,也可以从 Slave 订阅消息,订阅规则由 Broker 配置决定。

三、RocketMQ – RocketMQ 各种集群模式介绍

1、单 Master 模式

这种方式风险较大,一旦Broker重启或者宕机时,会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。

2、多 Master 模式

一个集群无 Slave,全是 Master,例如2个 Master 或者3个 Master,这种模式的优缺点如下:

  • 优点 : 配置简单,单个 Master 宕机或重启维护对应用无影响,在磁盘配置为 RAID10 时,即使机器宕机不可恢复情况下,由于 RAID10 磁盘非常可靠,消息也不会丢(异步刷盘丢失少量消息,同步刷盘一条不丢),性能最高;

  • 缺点:单台机器宕机期间,这台机器上未被消费的消息在机器恢复之前不可订阅,消息实时性会受到影响。

3、多 Master 多 Slave 模式(异步)

每个 Master 配置一个 Slave,有多对 Master-Slave,HA 采用异步复制方式,主备有短暂消息延迟(毫秒级),这种模式的优缺点如下:

  • 优点 :
    即使磁盘损坏,消息丢失的非常少,且消息实时性不会受影响,同时Master宕机后,消费者仍然可以从Slave消费,而且此过程对应用透明,不需要人工干预,性能同多Master模式几乎一样;

  • 缺点 :
    Master宕机,磁盘损坏情况下会丢失少量消息。

4、多 Master 多 Slave 模式(同步)

每个 Master 配置一个 Slave,有多对 Master-Slave,HA 采用同步双写方式,即只有主备都写成功,才向应用返回成功,这种模式的优
缺点如下:

  • 优点 :
    数据与服务都无单点故障,Master 宕机情况下,消息无延迟,服务可用性与数据可用性都非常高;

  • 缺点 :
    性能比异步复制模式略低(大约低10%左右),发送单个消息的RT会略高,且目前版本在主节点宕机后,备机不能自动切换为主机。

四、RocketMQ – 双主双从(2m-2s)集群介绍和工作流程说明

1、RocketMQ – 双主双从(2m-2s)集群介绍总体架构:消息高可用采用 2m-2s(同步双写)方式。

在这里插入图片描述

2、RocketMQ – 双主双从(2m-2s)集群工作流程说明

  • 1)启动 NameServer,NameServer 起来后监听端口,等待 Broker、Producer、Consumer 连上来,相当于一个路由控制中心。

  • 2)Broker 启动,跟所有的 NameServer 保持长连接,定时发送心跳包。心跳包中包含当前 Broker信息(IP+端口等)以及存储所有 Topic 信息。注册成功后,NameServer 集群中就有 Topic 跟 Broker 的映射关系。

  • 3)收发消息前,先创建 Topic,创建Topic时需要指定该 Topic 要存储在哪些 Broker 上,也可以在发送消息时自动创建 Topic。

  • 4) Producer 发送消息,启动时先跟 NameSErver 集群中的其中一台建立长连接,并从 NameServer 中获取当前发送的 Topic 存在哪些Broker 上,轮询从队列列表中选择一个队列,然后与队列所在的 Broker 建立长连接从而向 Broker 发消息。

  • 5) Consumer 跟 Producer 类似,跟其中一台 NameServer 建立长连接,获取当前订阅 Topic 存在哪些 Broker上,然后直接跟 Broker 建立连接通道,开始消费消息。

五、RocketMQ – 集群搭建1

1、RocketMQ–集群搭建–服务器环境

序号IP角色架构模式
1192.168.25.135nameserver、brokerserverMaster1、Slave2
2192.168.25.138nameserver、brokerserverMaster2、Slave1

2、RocketMQ–集群搭建–Host 添加信息

(在两个虚拟机上都要添加配置:192.168.25.135 和 192.168.25.138)


vim /etc/hosts
配置如下:

# nameserver
192.168.25.135 rocketmq-nameserver1
192.168.25.138 rocketmq-nameserver2

# broker
192.168.25.135 rocketmq-master1
192.168.25.135 rocketmq-slave2
192.168.25.138 rocketmq-master2
192.168.25.138 rocketmq-slave1

# 配置完成后,重启网卡
systemctl restart network

3、RocketMQ–集群搭建–防火墙配置

(在两个虚拟机上都要添加配置:192.168.25.135 和 192.168.25.138)

1)宿主机需要远程访问虚拟机的 rocketmq 服务和 web 服务,需要开放相关端口号,简单粗暴的方式是直接关闭防火墙。


# 关闭防火墙
systemctl stop firewalld.service 

# 查看防火墙状态
firewall -cmd --state 

# 禁止 firewall 开机启动
sysemctl disable firewalld.service 

2)或者为了安全,只开放特定的端口号,RocketMQ 默认使用3个端口:9876,10911,11011.如果防火墙没有关闭,那么防火墙就必须开放这几个端口。

  • nameserver 默认使用 9876 端口
  • master 默认使用 10911 端口
  • slave 默认使用 11011 端口

执行以下命令


# 开放 nameserver 默认使用 9876 端口
firewall -cmd --remove-port=9876/tcp --permanent

# 开放 master 默认使用 10911 端口
firewall -cmd --remove-port=10911/tcp --permanent

# 开放 slave 默认使用 11011 端口
firewall -cmd --remove-port=11011/tcp --permanent

# 重启防火墙
firewall -cmd --reload

4、RocketMQ–集群搭建–环境变量配置

(在两个虚拟机上都要添加配置:192.168.25.135 和 192.168.25.138)


vim /etc/profile

# 在profile文件的末尾加入如下命令

#set rocketmq
ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-all-4.5.1-bin-release
PATH=$PATH: $ROCKETMQ_HOME/bin
export ROCKETMQ_HOME PATH


# 输入: wq! 保存并退出,并使得配置立刻生效:
source /etc/profile

5、RocketMQ–集群搭建–创建消息存储路径

(在两个虚拟机上都要添加配置:192.168.25.135 和 192.168.25.138)


mkdir /usr/loca1/rocketmq/store
mkdir /usr/loca1/rocketmq/store/commitlog
mkdir /usr/local/rocketmq/store/consumequeue
mkdir /usr/local/rocketmq/store/index

六、RocketMQ – 集群搭建2

1、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.135 上的 broker 配置文件 配置 master1


vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字,注意此处不同的配置文件填写的不一样
brokerName=broker-a

# 0 表示 Master, >0 表示 slave
brokerid=0

# nameserver 地址,分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2: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=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

2、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.135 上的 broker 配置文件 配置 slave2



vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b-s.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字,注意此处不同的配置文件填写的不一样
brokerName=broker-b

# 0 表示 Master, >0 表示 slave
brokerid=1

# nameserver 地址,分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

# 在发送消息时,自动创建服务器不存在的 topic,默认创建的队列数
defaultTopicQueueNums=4

# 是否允许 Broker 自动创建Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true

# 是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭
autocreatesubscriptionGroup=true

# Broker 对外服务的监听端口
listenPort=11011

# 删除文件时间点,默认凌晨4点
deletewhen=04

# 文件保留时间,默认48小时
fileReservedTime=120

# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每个文件默认存30W条,根据业务情况调整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88

# 存储路径
storePathRootDir=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SLAVE

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128


3、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.138 上的 broker 配置文件 配置 master2


vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字,注意此处不同的配置文件填写的不一样
brokerName=broker-b

# 0 表示 Master, >0 表示 slave
brokerid=0

# nameserver 地址,分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2: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=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

4、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.138 上的 broker 配置文件 配置 slave1


vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a-s.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字,注意此处不同的配置文件填写的不一样
brokerName=broker-a

# 0 表示 Master, >0 表示 slave
brokerid=1

# nameserver 地址,分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

# 在发送消息时,自动创建服务器不存在的 topic,默认创建的队列数
defaultTopicQueueNums=4

# 是否允许 Broker 自动创建Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true

# 是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭
autocreatesubscriptionGroup=true

# Broker 对外服务的监听端口
listenPort=11011

# 删除文件时间点,默认凌晨4点
deletewhen=04

# 文件保留时间,默认48小时
fileReservedTime=120

# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每个文件默认存30W条,根据业务情况调整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88

# 存储路径
storePathRootDir=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SLAVE

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

5、RocketMQ–集群搭建2–broker 配置文件 注意事项:


# 1)进入 broker 配置文件 目录:

cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/

# 2)注意配置端口号,不要冲突

- nameserver 默认使用 9876 端口
- master 默认使用 10911 端口
- slave 默认使用 11011 端口

# 3)注意修改的 broker 配置文件名和端口号(同一虚拟机服务器端口号不能重复) 

192.168.25.135 rocketmq-master1  vim broker-a.properties 端口:10911
192.168.25.135 rocketmq-slave2   vim broker-b-s.properties 端口:11011

192.168.25.138 rocketmq-master2  vim broker-b.properties 端口:10911
192.168.25.138 rocketmq-slave1   vim broker-a-s.properties  端口:11011

七、RocketMQ – 集群搭建3

1、RocketMQ–集群搭建3–修改启动脚本文件

(注意:在两个虚拟机上都要修改配置:192.168.25.135 和 192.168.25.138)


# 1)修改 runbroker.sh

vi /usr/1oca1/rocketmq/rocketmq-all-4.5.1-bin-release/bin/runbrokeF.sh

# 需要根据内存大小进行适当的对JVM参数进行调整:

# 开发环境配置 JVM Configuration
JAVA_OPT="${JAVA_OPT} -server -xms256m -Xmx256m -Xmn128m"

# 2) 修改 runserver.sh

vim /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -xms256m -xmx256m -Xmn128m-XX:Metaspacesize=128m-
XX:MaxMetaspacesize=320m"

2、RocketMQ–集群搭建3–服务启动


# 1)启动 NameServe 集群

# 分别在 192.168.25.135 和 192.168.25.138 启动 NameServer

# 切换目录
cd /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 NameServe 
nohup sh mqnamesrv &

# 查看启动结果
jps 


# 2)启动 Broker 集群--# 在 192.168.25.135 上启动 master1 和 slave2

# master1  切换目录 
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 master1
nohup sh mqbroker -c /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a.properties &

# slave2:  切换目录
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 slave2
nohup sh mqbroker -c /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b-s.properties &

# 查看启动结果
jps 


# 3)启动 Broker 集群--# 在 192.168.25.138 上启动 master2 和 slave1

# master2  切换目录 
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 master2
nohup sh mqbroker -c /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b.properties &

# slave1:  切换目录
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 slave1
nohup sh mqbroker -c /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a-s.properties &

# 查看启动结果
jps 


3、RocketMQ–集群搭建3–查看进程状态和查看日志


# 1)启动后通过 jps 查看启动进程
jps 

# 2)查看日志

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

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

八、RocketMQ – 双主双从集群搭建小结

1、总体架构

2、集群搭建工作流程

3、服务器环境

4、Host 添加信息

5、防火墙配置

6、环境变量配置

7、创建消息存储路径

8、broker 配置文件

9、修改启动脚本文件

10、服务启动

11、查看进程状态

12、查看日志。

上一节关联链接请点击:

# 全面解剖 消息中间件 RocketMQ-(1)

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

全网最全爬取-b站爬取弹幕+评论之js逆向与xml降本增效

🌟 ❤️ 作者:yueji0j1anke 首发于公号:剑客古月的安全屋 字数:801 阅读时间: 10min 声明:请勿利用文章内的相关技术从事非法测试,由于传播、利用此文所提供的信息而造成的任何直接或者间接的后果及…

K-means聚类模型

目录 1.定义 2.K-means聚类模型的优点 3.K-means聚类模型的缺点 4.K-means聚类模型的应用场景 5.对K-means聚类模型未来的展望 6.小结 1.定义 什么是 K-means 聚类模型?K-means 聚类模型是一种无监督学习算法,用于将数据划分为不同的组或簇&#…

概念+bug

模型 迭代模型和增量模型 增量模型是将一个大的需求变成小的功能,然后将每个功能逐个开发几乎完整再上线。 迭代模型会上线一个基础版本,但是基础版本所有的功能都有但是非常简陋,之后再迭代优化上线。 一般都是两个一起用,不…

微服务Day7学习

文章目录 数据聚合聚合分类 自动补全DSL实现Bucket聚合DSL实现Metrics聚合RestAPI实现聚合多条件聚合对接前端接口拼音分词器自定义分词器自动补全查询实现酒店搜索框自动补全 数据同步数据同步思路分析利用mq实现mysql与elasticsearch数据同步 集群介绍搭建ES集群 数据聚合 聚…

T01.如何寻找隐藏目录usr?

当我们打开Mac自带的Shell或者另外安装的zsh等工具时,我们所在的默认目录为用户目录usr。 Mac的这个bin目录,是一个已经包含在环境变量里的目录,程序放在里面或者链接到里面就可以在终端里直接执行。Mac的usr/bin目录是不允许增删文件的&…

tomcat三级指导

版本 ./catalina.sh linux version.bat win 1.确认是否使用了tomcat管理后台 我们先找到配置文件:tomcat主目录下/conf/server.xml 可以查看到连接端口,默认为8080 然后查看manager-gui管理页面配置文件,是否设置了用户登录 配置文件…

Obsidian Git 多端同步

2023年6月,某云笔记限制了免费用户最多同时登录 2 台设备,想要增加设备数量需要付费开通会员。之后我一直想找一款合适的笔记本软件,年底尝试了Obsidian,断断续续摸索了好几天终于成功了。将那时的笔记拿来分享一下。 相关地址&am…

Java轻松转换Markdown文件到Word和PDF文档

Markdown 凭借其简洁易用的特性,成为创建和编辑纯文本文档的常用选择。但某些时候我们需要更加精致的展示效果,例如在专业分享文档或打印成离线使用的纸质版时,就需要将Markdown文件以其他固定的文档格式呈现。通过将 Markdown 转换为 Word 和…

错误代码126:加载x3daudio1_7.dll失败的几种修复方法分享

在使用电脑玩游戏或者工作的过程中,我们经常会遇到一些错误提示,其中最常见的就是“错误代码[126]:加载x3daudio1_7.dll失败,该文件缺失或损坏!”,那么,什么是x3daudio17.dll文件?它为什么会丢失&#xff1…

剪画小程序:3个方法:告诉你如何将普通的照片转换成动漫二次元风格!

Hello!亲爱的小伙伴们! 你是否还在纠结于自己的自拍太普通,每次分享到社交账号上都觉得平平无奇,引不起波澜? 假如,你和朋友们一起出去玩,大家都开心地拍着自拍。你看着自己的照片&#xff0c…

多联机分户计费控制系统

中央空调多联机分户计费控制系统,针对国内常见几种品牌的多联机空调系统实行,远程控制与计费管理。系统采用MQTT网络协议,以订阅/发布模式实行设备感知,实现对室外机、室内机的状态监测、实时故障报警、累计分摊费用的实时数据传导…

SSMP整合案例第一步 制作分析模块创建与开发业务实体类

制作分析 我们要实现一个模块的增删改查 实际开发中mybatisplus用的不多,他只能对没有外键的单表进行简单的查询 但在这个案例中我们还是选择mybatisplus开发 模块创建 我们把所有服务器都放在一起 就不用前后端分离 我们尝试用后端开发进行全栈开发 新建项目添…

C++语法|多重继承详解(一)|理解虚基类和虚继承

系列汇总讲解,请移步: C语法|虚函数与多态详细讲解系列(包含多重继承内容) 虚基类是多重继承知识上的铺垫。 首先我们需要明确抽象类和虚基类的区别: 抽象类:有纯虚函数的类 虚基类是什么呢&a…

精选ThingsBoard物联网关

Thingsboard网关BL104 ThingsBoard物联网网关是一个指可以将数据采集转发至ThingsBoard平台的物联网网关,它使用且仅使用MQTT协议与ThingsBoard平台(ThingsBoard IoT Platform)进行通讯。这个网关为ThingsBoard平台提供支持更多协议的数据收…

poi操作word模板,对原有的word修改

/*** 化工园区调查表** param templatePath* param outPath* param parkInterview*/public static String getDocx(String templatePath, String outPath, ParkInterview parkInterview){File file new File(templatePath);File file1 new File(outPath);if(!file1.exists()…

2024 年 电工杯(B题)大学生数学建模挑战赛 | 平衡膳食食谱 | 数学建模完整代码+建模过程全解全析

当大家面临着复杂的数学建模问题时,你是否曾经感到茫然无措?作为2022年美国大学生数学建模比赛的O奖得主,我为大家提供了一套优秀的解题思路,让你轻松应对各种难题。 CS团队倾注了大量时间和心血,深入挖掘解决方案。通…

怎么查看公网IP?

在网络通信中,每个设备都会被分配一个IP地址,用于在互联网上进行唯一标识和通信。公网IP是指可以被公开访问的IP地址,可以用来建立远程连接或者进行网络访问等操作。怎么查看公网IP呢?下面将介绍几种常用的方法。 使用命令行查询公…

《中国企业报》集团数字产业发展研究院介绍

《中国企业报》集团数字产业发展研究院(以下简称“中企数研院”),隶属于《中国企业报》集团管理。“中企数研院”致力于“数字经济产业化发展战略”大背景下,以“县域数字经济”、“企业数字化转型”及“数字人民币”推广等发展方…

图像超分辨率重建相关概念、评价指标、数据集、模型

1、图像超分辨率概念 1.1 基本定义 超分辨率(Super-Resolution),简称超分(SR)。是指利用光学及其相关光学知识,根据已知图像信息恢复图像细节和其他数据信息的过程,简单来说就是增大图像的分辨…