RocketMQ的介绍和环境搭建

news2025/1/17 4:04:32

一、介绍

我也不知道是啥，知道有什么用、怎么用就行了，说到mq（MessageQueue）就是消息队列，队列是先进先出的一种数据结构，但是RocketMQ不一定是这样，简单的理解一下，就是临时存储的数据的一个临时仓库，货送到了就行了

作用一般有三个

  1. 异步：服务器把客户端请求放到RocketMQ，服务器就可以继续处理其它请求，RocketMQ可以按照自己的规则推送到对应的服务器进行处理
  2. 解耦：比如订单服务和库存服务直接，如果不用队列，下单必须等库存响应才能返回，这样依赖性太强，服务中间加入中间件可以降低服务直接的依赖
  3. 削峰：洪峰流量时，大量请求涌入，如果处理不过来服务器就容易瘫痪，就像处理水患一样，中间挖一个坑蓄水，RocketMQ就相当于这个坑，再把消息发到对应的下游服务器

二、单机部署

RocketMQ下载地址：下载 | RocketMQ

对bin目录下的runserver.sh和runbroker.sh两个脚本进行一下修改，主要是jvm的的内存参数设置

vim runserver.sh
# 找到choose_gc_options 根据jdk版本配置合适的内存大小
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

vim runbroker.sh
# 找到choose_gc_options 根据jdk版本配置合适的内存大小
JAVA_OPT="${JAVA_OPT} -Xmn512m -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSParallelRemarkEnabled -XX:SoftRefLRUPolicyMSPerMB=0 -XX:+CMSClassUnloadingEnabled -XX:SurvivorRatio=8 -XX:-UseParNewGC"
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"

1、启动nameserver服务

cd /usr/local/rocketmq/rocketmq-all-5.0.0-bin-release
# 后台启动
nohup bin/mqnamesrv &
# 查看是否启动成功
less nohup.out
# 查看java进程NamesrvStartup服务
jps

2、启动broker服务

配置环境遍历NAMESRV_ADDR 

vi ~/.profile
#最后一行添加如下内容
export NAMESRV_ADDR='localhost:9876'
#source生效
source ~/.profile

启动broker服务 

cd /usr/local/rocketmq/rocketmq-all-5.0.0-bin-release
vim conf/broker.conf
#在最后一行添加如下 意思是开启自动创建topic
autoCreateTopicEnable=true
#启动broker
nohup bin/mqbroker &
# 查看是否启动成功
less nohup.out
# 查看java进程BrokerStartup服务
jps

3、关闭

1）、在实际服务部署时，通常会将RocketMQ的部署地址添加到环境变量当中。例如使用vi ~/.bash_profile指令，添加以下内容。

export ROCKETMQ_HOME=/app/rocketmq/rocketmq-all-4.9.5-bin-releasePATH=$ROCKETMQ_HOME/bin:$PATHexport PATH

这样就不必每次进入RocketMQ的安装目录了。直接可以使用mqnamesrv 和mqbroker指令。

2）、停止RocketMQ服务可以通过mqshutdown指令进行

mqshutdown namesrv # 关闭nameserver服务

mqshutdown broker # 关闭broker服务

4、测试收发消息

#通过指令启动RocketMQ的消息生产者发送消息
bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
#启动消息消费者接收之前发送的消息
bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

5、搭建RocketMQ可视化界面

在RocketMQ下载页找到RocketMQ Dashboard进行源码的下载，解压后在maven环境下进行编译

mvn clean package -Dmaven.test.skip=true

 编译完成后，在源码的target目录下会生成可运行的jar包rocketmq-dashboard-1.0.0.jar。接下来可以将这个jar包上传到服务器上

cd /usr/local/rocketmq
mkdir rocketmq-dashboard
cd rocketmq-dashboard
#上传文件到此目录后，新建application.yml（如果出现错误可以不添加yml文件）
vim application.yml
application.yml内容如下
rocketmq: 
  config: 
    namesrvAddrs: 
      - 192.168.146.128:9876

#结果启动RocketMQ可视化界面的jar包
java -jar rocketmq-dashboard-1.0.0.jar 1>dashboard.log 2>&1 &

查看dashboard.log文件们没有报错的情况下访问部署的所在机器的ip:8080（默认）

三、集群搭建

如果单节点部署，nameserver或者broker挂了都不能正常访问RocketMQ了，针对这种情况可以基于集群部署，先是对集群做了如下部署规划

不要想用一台机器来搭建，否则就会出现这个错误

正式开始，下面开了三台机器，ip依次是192.168.64.133、192.168.64.134、192.168.64.128

第一步，先按照之前的步骤配置nameserver然后启动
#三台机器启动nameserver都是一样的操作
cd /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release
vim bin/runserver.sh
# 找到choose_gc_options 根据jdk版本配置合适的内存大小
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
# 后台启动
nohup bin/mqnamesrv &
# 查看是否启动成功
less nohup.out
# 查看java进程NamesrvStartup服务
jps
第二步配置并启动broker主从集群

1）、在192.168.64.133上配置broker-a，修改conf/2m-2s-async/broker-a.properties，把原来的注释掉，添加如下内容

#所属集群名字，名字一样的节点就在同一个集群内
brokerClusterName=rocketmq-cluster
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-a
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
deleteWhen=04
fileReservedTime=120
#存储路径
storePathRootDir=/usr/local/rocketmq/store
storePathCommitLog=/usr/local/rocketmq/store/commitlog
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
storePathIndex=/usr/local/rocketmq/store/index
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
abortFile=/usr/local/rocketmq/store/abort
#Broker 的角色
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911

2）、在192.168.64.134上配置broker-a的slave，修改conf/2m-2s-async/broker-a-s.properties，把原来的注释掉，添加如下内容

#所属集群名字，名字一样的节点就在同一个集群内
brokerClusterName=rocketmq-cluster
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-a
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
deleteWhen=04
fileReservedTime=120
#存储路径
storePathRootDir=/usr/local/rocketmq/storeSlave
storePathCommitLog=/usr/local/rocketmq/storeSlave/commitlog
storePathConsumeQueue=/usr/local/rocketmq/storeSlave/consumequeue
storePathIndex=/usr/local/rocketmq/storeSlave/index
storeCheckpoint=/usr/local/rocketmq/storeSlave/checkpoint
abortFile=/usr/local/rocketmq/storeSlave/abort
#Broker 的角色
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=11011

3）、在192.168.64.134上配置broker-b，修改conf/2m-2s-async/broker-b.properties，把原来的注释掉，添加如下内容

#所属集群名字，名字一样的节点就在同一个集群内
brokerClusterName=rocketmq-cluster
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-b
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
deleteWhen=04
fileReservedTime=120
#存储路径
storePathRootDir=/usr/local/rocketmq/store
storePathCommitLog=/usr/local/rocketmq/store/commitlog
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
storePathIndex=/usr/local/rocketmq/store/index
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
abortFile=/usr/local/rocketmq/store/abort
#Broker 的角色
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911

4）、在192.168.64.133上配置broker-b的slave，修改conf/2m-2s-async/broker-b-s.properties，把原来的注释掉，添加如下内容

#所属集群名字，名字一样的节点就在同一个集群内
brokerClusterName=rocketmq-cluster
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-b
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
deleteWhen=04
fileReservedTime=120
#存储路径
storePathRootDir=/usr/local/rocketmq/storeSlave
storePathCommitLog=/usr/local/rocketmq/storeSlave/commitlog
storePathConsumeQueue=/usr/local/rocketmq/storeSlave/consumequeue
storePathIndex=/usr/local/rocketmq/storeSlave/index
storeCheckpoint=/usr/local/rocketmq/storeSlave/checkpoint
abortFile=/usr/local/rocketmq/storeSlave/abort
#Broker 的角色
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=11011

​ 这样就完成了2主2从集群的配置。配置过程汇总有几个需要注意的配置项：

  • store开头的一系列配置：表示RocketMQ的存盘文件地址。在同一个机器上需要部署多个Broker服务时，不同服务的存储目录不能相同。

  • listenPort：表示Broker对外提供服务的端口。这个端口默认是10911。在同一个机器上部署多个Broker服务时，不同服务占用的端口也不能相同。

  • 如果你使用的是多网卡的服务器，比如阿里云上的云服务器，那么就需要在配置文件中增加配置一个brokerIP1属性，指向所在机器的外网网卡地址。

第三步，启动broker服务

在启动之前还是需要配置jvm参数（所有机器都一样）

vim bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"

先启动在192.168.64.133的broker-a和broker-b-s服务

cd /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release
nohup bin/mqbroker -c ./conf/2m-2s-async/broker-a.properties &
nohup bin/mqbroker -c ./conf/2m-2s-async/broker-b-s.properties &

再启动192.168.64.134的broker-b和broker-a-s服务

cd /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release
nohup bin/mqbroker -c ./conf/2m-2s-async/broker-b.properties &
nohup bin/mqbroker -c ./conf/2m-2s-async/broker-a-s.properties &
第四步，检查broker集群状态
bin/mqadmin clusterList

也可以通过rocketmq dashboard查看，我之前添加yml启动报错，不知道怎么回事，欢迎大佬留言解决，其实rocketmq dashboard可以这样配置nameserver的地址

rocketmq: 
  config: 
    namesrvAddrs: 
      - 192.168.64.133:9876 
      - 192.168.64.134:9876
      - 192.168.64.128:9876

具体查看集群结果就是如图

​ 在RocketMQ的这种主从架构的集群下，客户端发送的消息会分散保存到broker-a和broker-b两个服务上，然后每个服务都配有slave服务，可以备份对应master服务上的消息，这样就可以防止单点故障造成的消息丢失问题。 

有个问题就是主节点挂了，为了保证数据的完整性不会选举新的主节点，因为如果因为网络波动出现脑裂问题很有可能会丢失数据

把broker-b和broker-a-s也就是把192.168.64.134的broker服务停掉，看下什么状态，操作如下命令

bin/mqshutdown broker

四、升级高可用集群

在Dledger集群中，就不再单独指定各个broker的服务，而是由这些broker服务自行进行选举，产生一个Leader角色的服务，响应客户端的各种请求。而其他的broker服务，就作为Follower角色，负责对Leader上的数据进行备份 

Dledger集群的选举是通过Raft协议进行的，Raft协议是一种多数同意机制。也就是每次选举需要有集群中超过半数的节点确认，才能形成整个集群的共同决定。同时，这也意味着在Dledger集群中，只要有超过半数的节点能够正常工作，那么整个集群就能正常工作。因此，在部署Dledger集群时，通常都是部署奇数台服务，这样可以让集群的容错性达到最大。

还是用之前的机器，ip依次是192.168.64.133、192.168.64.134、192.168.64.128

第一步：部署nameserver

这一步和之前部署主从集群没有区别，不需要做过多的配置，直接在三台服务器上启动nameserver服务即可。

第二步：对Broker服务进行集群配置

 在conf/dledger目录下，RocketMQ默认给出了三个配置文件，这三个配置文件可以在单机情况下直接部署成一个具有三个broker服务的Dledger集群，我们只需要按照这个配置进行修改即可。

注：在RocketMQ运行包的bin/dledger目录下，RocketMQ还提供了一个fast-try.sh脚本。这个脚本会指定conf/deldger目录下的配置文件，直接启动有三个broker服务的Dledger集群。每个集群指定的内存大小占用1G。

在三台机器的conf/dledger目录下，都创建一个broker.conf文件，对每个broker服务进行配置。

192.168.64.133的broker.conf配置示例

vim /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release/conf/dledger/broker.conf
# 文件内容如下
brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30911
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
storePathRootDir=/usr/local/rocketmq/storeDledger/
storePathCommitLog=/usr/local/rocketmq/storeDledger/commitlog
storePathConsumeQueue=/usr/local/rocketmq/storeDledger/consumequeue
storePathIndex=/usr/local/rocketmq/storeDledger/index
storeCheckpoint=/usr/local/rocketmq/storeDledger/checkpoint
abortFile=/usr/local/rocketmq/storeDledger/abort
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-192.168.64.133:40911;n1-192.168.64.134:40911;n2-192.168.64.128:40911
## must be unique
dLegerSelfId=n0
sendMessageThreadPoolNums=16

192.168.64.134的broker.conf配置示例

vim /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release/conf/dledger/broker.conf
# 文件内容如下
brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30911
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
storePathRootDir=/usr/local/rocketmq/storeDledger/
storePathCommitLog=/usr/local/rocketmq/storeDledger/commitlog
storePathConsumeQueue=/usr/local/rocketmq/storeDledger/consumequeue
storePathIndex=/usr/local/rocketmq/storeDledger/index
storeCheckpoint=/usr/local/rocketmq/storeDledger/checkpoint
abortFile=/usr/local/rocketmq/storeDledger/abort
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-192.168.64.133:40911;n1-192.168.64.134:40911;n2-192.168.64.128:40911
## must be unique
dLegerSelfId=n1
sendMessageThreadPoolNums=16

192.168.64.128的broker.conf配置示例

vim /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release/conf/dledger/broker.conf
# 文件内容如下
brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30911
namesrvAddr=192.168.64.133:9876;192.168.64.134:9876;192.168.64.128:9876
storePathRootDir=/usr/local/rocketmq/storeDledger/
storePathCommitLog=/usr/local/rocketmq/storeDledger/commitlog
storePathConsumeQueue=/usr/local/rocketmq/storeDledger/consumequeue
storePathIndex=/usr/local/rocketmq/storeDledger/index
storeCheckpoint=/usr/local/rocketmq/storeDledger/checkpoint
abortFile=/usr/local/rocketmq/storeDledger/abort
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-192.168.64.133:40911;n1-192.168.64.134:40911;n2-192.168.64.128:40911
## must be unique
dLegerSelfId=n2
sendMessageThreadPoolNums=16

这里对几个需要重点关注的配置项，做下介绍：

  • enableDLegerCommitLog: 是否启动Dledger。true表示启动

  • namesrvAddr: 指定nameserver地址

  • dLedgerGroup: Dledger Raft Group的名字，建议跟brokerName保持一致。

  • dLedgerPeers: Dledger Group内各个服务节点的地址及端口信息。同一个Group内的各个节点配置必须要保持一致。

  • dLedgerSelfId: Dledger节点ID，必须属于dLedgerPeers中的一个。同一个Group内的各个节点必须不能重复。

  • sendMessageThreadPoolNums：dLedger内部发送消息的线程数，建议配置成cpu核心数。

  • store开头的一系列配置： 这些是配置dLedger集群的消息存盘目录。如果你是从主从架构升级成为dLedger架构，那么这个地址可以指向之前搭建住主从架构的地址。dLedger集群会兼容主从架构集群的消息格式，只不过主从架构的消息无法享受dLedger集群的两阶段同步功能。

第三步：启动broker服务

和启动主从架构的broker服务一样，我们只需要在启动broker服务时，指定配置文件即可。在三台服务器上分别执行以下指令，启动broker服务

cd /usr/local/rocketmq/rocketmq-all-4.9.5-bin-release
nohup bin/mqbroker -c conf/dledger/broker.conf &
第四步：检查集群服务状态

通过rocketmq dashboard查看

停掉192.168.64.128之后的dashboard

不能停了，再停宕机超过半数只剩一台就无法选举产生新的master 

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

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

相关文章

功率谱密度PSD(笔记)

功率谱密度PSD(笔记)

能量守恒：时域能量等于频域能量 功率谱密度能够反映随机振动的功率关于频率的分布密度 功率谱密度（PSD）：单位是功率/Hz。针对功率有限信号(能量有限信号用能量谱密度)。表现为是单位频带内信号功率随频率的变换情况，…
阅读更多...
【深度学习】Pytorch 系列教程（十一）：PyTorch数据结构：3、变量（Variable）介绍

【深度学习】Pytorch 系列教程（十一）：PyTorch数据结构：3、变量（Variable）介绍

目录 一、前言 二、实验环境 三、PyTorch数据结构 0、分类 1、张量（Tensor） 2、张量操作（Tensor Operations） 3、变量（Variable） 一、前言 ChatGPT： PyTorch是一个开源的机器学习框架&am…
阅读更多...
Vulnhub系列靶机---Deathnote: 1死亡笔记

Vulnhub系列靶机---Deathnote: 1死亡笔记

文章目录 信息收集主机发现端口扫描目录扫描dirsearchgobusterdirb扫描 漏洞利用wpscan扫描Hydra爆破 总结 靶机文档：Deathnote: 1 下载地址：Download (Mirror) 难易程度：so Easy 信息收集 主机发现 端口扫描 访问靶机的80端口，报…
阅读更多...
什么是 Microsoft Office 365？ Excel on Cloud 的好处

什么是 Microsoft Office 365？ Excel on Cloud 的好处

什么是Office 365 Office 365 是 Microsoft 的一套程序，可以在本地运行，也可以同步到云存储。 可以从访问程序。 借助 Office 365，您可以在任何地方进行工作，并与世界各地的同事共享工作文档。 Office 365 支持的设备&#xff1a…
阅读更多...
涵盖Java核心知识的综合指南：JavaGuide | 开源日报 0912

涵盖Java核心知识的综合指南：JavaGuide | 开源日报 0912

Snailclimb/JavaGuide Stars: 133.8k License: Apache-2.0 这是一份涵盖大部分 Java 程序员所需要掌握的核心知识库。该项目包含了 Java 基础、集合、IO、并发等方面的内容，并提供了重要知识点详解和源码分析。此外还有计算机基础（操作系统、网络&…
阅读更多...
题目 1057: 二级C语言-分段函数

题目 1057: 二级C语言-分段函数

有一个函数如下，写一程序，输入x，输出y值。 保留两位小数 样例输入 1 样例输出 1.00 这道题的思路很简单，我直接用if判断输入的X对应的函数Y的区间，代入对应的函数，求出结果。记得变量用浮点型&#xff…
阅读更多...
【异常错误】detected dubious ownership in repository ****** is owned by: ‘

【异常错误】detected dubious ownership in repository ****** is owned by: ‘

今天在github git的时候，突然出现了这种问题，下面的框出的部分一直显示： detected dubious ownership in repository at D:/Pycharm_workspace/SBDD/1/FLAG D:/Pycharm_workspace/SBDD/1/FLAG is owned by: S-1-5-32-544 but the current use…
阅读更多...
Arm发布 Neoverse V2 和 E2：下一代 Arm 服务器 CPU 内核

Arm发布 Neoverse V2 和 E2：下一代 Arm 服务器 CPU 内核

9月14日，Arm发布了新的处理器内核：V2和E2，在官网已经可以看到相关的TRM 手册了。。 四年前，Arm发布了Neoverse系列的CPU设计。Arm决定加大力度进军服务器和边缘计算市场，专门为这些市场设计Arm CPU内核，而…
阅读更多...
UART 协议

UART 协议

文章目录 硬件拓扑基本原理起始位数据帧奇偶校验位停止位 参考 硬件拓扑 在 UART 通信中，两个 UART 直接相互通信。发送 UART 将控制设备（如 CPU）的并行数据转换为串行形式，以串行方式将其发送到接收 UART。只需要两条线即可在两…
阅读更多...
elementUI elfrom表单验证无效、不起作用常见原因

elementUI elfrom表单验证无效、不起作用常见原因

今天遇到一个变态的问题&#xff0c;因页面比较复杂&#xff0c;出现几组条件判断&#xff0c;每个template内部又包含很多表单&#xff01;&#xff01; <template v-if"transformTypeValue 1"></template><template v-else-if"transformTypeV…
阅读更多...
项目知识点总结-分页（三）

项目知识点总结-分页（三）

后端分页查询接口&#xff1a; Controller Service&#xff1a; Mapper&#xff1a; //分页搜索会议的方法List<SearchMeeting> getAllSearchMeeting(Param("sm") SearchMeeting searchMeeting,Param("page") Integer page,Param("pageSize&q…
阅读更多...
黑马JVM总结（十）

黑马JVM总结（十）

&#xff08;1&#xff09;直接内存_基本使用 下面我们看一下使用了ByteBuffer直接内存&#xff0c;大文件的读写效率是非常的高 Java本身并不具备磁盘读写的能力&#xff0c;它需要调用操作系统的函数&#xff0c;需要从java的方法内部调用本地方法操作系统的方法&#xff0c…
阅读更多...
Multitor：一款带有负载均衡功能的多Tor实例创建工具

Multitor：一款带有负载均衡功能的多Tor实例创建工具

关于Multitor Multitor是一款带有负载均衡功能的多Tor实例创建工具&#xff0c;Multitor的主要目的是以最快的速度完成大量Tor进程的初始化&#xff0c;并将大量实例应用到我们日常使用的程序中&#xff0c;例如Web浏览器和聊天工具等等。除此之外&#xff0c;在该工具的帮助下…
阅读更多...
火山引擎 ByteHouse：ClickHouse 如何保证海量数据一致性

火山引擎 ByteHouse：ClickHouse 如何保证海量数据一致性

背景 ClickHouse是一个开源的OLAP引擎&#xff0c;不仅被全球开发者广泛使用&#xff0c;在字节各个应用场景中也可以看到它的身影。基于高性能、分布式特点&#xff0c;ClickHouse可以满足大规模数据的分析和查询需求&#xff0c;因此字节研发团队以开源ClickHouse为基础&…
阅读更多...
国内AI语言大模型【文心一言】介绍

国内AI语言大模型【文心一言】介绍

一、前言 文心一言是一个知识增强的大语言模型，基于飞桨深度学习平台和文心知识增强大模型，持续从海量数据和大规模知识中融合学习具备知识增强、检索增强和对话增强的技术特色。 最近收到百度旗下产品【文心一言】的产品，抱着试一试的心态体验了一下，整体感觉：还行！ 二…
阅读更多...
OpenMV与STM32之间的通信（附源码）

OpenMV与STM32之间的通信（附源码）

本篇文章旨在记录我电赛期间使用openmv和stm32单片机之间进行串口通信&#xff0c;将openmv识别到的坐标传输给单片机。背景是基于2023年全国大学生电子设计大赛E题&#xff1a;舵机云台追踪识别。 单片机的串口通信原理我便不再详细讲解&#xff0c;下面直接上代码分析。 值得…
阅读更多...
SpringBoot分页其实很简单

SpringBoot分页其实很简单

分页其实很简单 一、数据库Limit Limit的使用 Limit子句可以被用于强制 SELECT 语句返回指定的记录数。 Limit接受一个或两个数字参数&#xff0c;参数必须是一个整数常量。如果给定两个参数&#xff0c;第一个参数指定第一个返回记录行的偏移量&#xff0c;第二个参数指定返…
阅读更多...
Java————初始集合框架

Java————初始集合框架

一 、 集合框架 Java 集合框架Java Collection Framework &#xff0c;又被称为容器container &#xff0c; 是定义在 java.util 包下的一组接口interfaces 和其实现类classes 。 其主要表现为将多个元素element 置于一个单元中&#xff0c; 用于对这些元素进行快速、便捷的存…
阅读更多...
题目 1056: 二级C语言-温度转换

题目 1056: 二级C语言-温度转换

输入一个华氏温度&#xff0c;要求输出摄氏温度。公式为 保留两位小数 样例输入 -40.00 样例输出 -40.00 这道题很简单&#xff0c;数据代入公式就行。记得设置double或者float的浮点型--》用于保留两位小数。 对于保留小数: 1是可以用iomanip的cout<<fixed<&l…
阅读更多...
Mysql的逻辑架构、存储引擎

Mysql的逻辑架构、存储引擎

1. 逻辑架构剖析 1.1 服务器处理客户端请求 首先MySQL是典型的C/S架构&#xff0c;即Clinet/Server 架构&#xff0c;服务端程序使用的mysqld。 不论客户端进程和服务器进程是采用哪种方式进行通信&#xff0c;最后实现的效果是&#xff1a;客户端进程向服务器进程发送一段文…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023