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

Redis Stream消息队列之基本语法与使用方式

news 文章来源：https://blog.csdn.net/Cai181191/article/details/135171123 2024/9/22 23:18:11

前言

本文的主角是Redis Stream，它是Redis5.0版本新增加的数据结构，主要用于消息队列，提供了消息的持久化和主备复制功能，可以让任何客户端访问任何时刻的数据，并且能记住每一个客户端的访问位置，还能保证消息不丢失，功能颇为强大。其实，Redis本身是有一个Redis发布订阅来实现消息队列的功能，但它有个缺点就是消息无法持久化，如果出现网络断开、Redis宕机等，消息就会被丢弃。所以，Redis的发布订阅像是Vue2的Bus或Vue3的Mitt，属于后端版的事件总线。此外，Redis本身的List和Sorted Set也可以实现，但是也有各自的缺点，如List没有消息多播功能，没有ACK机制，无法重复消费等，Sorted Set不支持阻塞式获取消息、不允许重复消费、不支持分组。相比之下，Redis Stream明显胜出。

一、消息队列相关命令

1.XADD - 添加消息到末尾

（1）语法格式：

XADD key ID field value

（2）参数：

  • key：队列名称，如果不存在就创建
  • ID：消息ID，我们使用*表示由redis生成，可以自定义，但是要自己保证递增性。
  • field value：记录。

（3）示例：

127.0.0.1:6379[15]> XADD MQ * name Vegeta sex male age 18
"1703235642574-0"
127.0.0.1:6379[15]> XADD MQ * name Bulma sex female age 18
"1703235648454-0"
127.0.0.1:6379[15]>

2.XLEN - 获取流包含的元素数量，即消息长度

（1）语法格式：

XLEN key

（2）参数：

  • key：队列名称。

（3）示例：

127.0.0.1:6379[15]> XLEN MQ
(integer) 2

3.XRANGE - 获取消息列表，会自动过滤已经删除的消息

（1）语法格式：

XRANGE key start end [COUNT count]

（2）参数：

  • key：队列名
  • start：开始值，- 表示最小值
  • end：结束值，+ 表示最大值
  • count：数量

（3）示例：

127.0.0.1:6379[15]> XRANGE MQ - +
1) 1) "1703235642574-0"2) 1) "name"2) "Vegeta"3) "sex"4) "male"5) "age"6) "18"
2) 1) "1703235648454-0"2) 1) "name"2) "Bulma"3) "sex"4) "female"5) "age"6) "18"

4.XREVRANGE - 反向获取消息列表，ID从大到小

（1）语法格式：

XREVRANGE key end start [COUNT count]

（2）参数：

  • key：队列名
  • end：结束值，+ 表示最大值
  • start：开始值，- 表示最小值
  • count：数量

（3）示例：

127.0.0.1:6379[15]> XREVRANGE MQ + - COUNT 2
1) 1) "1703235648454-0"2) 1) "name"2) "Bulma"3) "sex"4) "female"5) "age"6) "18"
2) 1) "1703235642574-0"2) 1) "name"2) "Vegeta"3) "sex"4) "male"5) "age"6) "18"

5.XDEL - 删除消息

（1）语法格式：

XDEL key ID [ID ...]

（2）参数：

  • key：队列名称
  • ID：消息 ID

（3）示例：

127.0.0.1:6379[15]> XADD MQ * name Kakarotto sex male age 18
"1703238230846-0"
127.0.0.1:6379[15]> XADD MQ * name Android18 sex female age 18
"1703238306386-0"
127.0.0.1:6379[15]> XDEL MQ 1703238230846-0
(integer) 1
127.0.0.1:6379[15]> XRANGE MQ - +
1) 1) "1703235642574-0"2) 1) "name"2) "Vegeta"3) "sex"4) "male"5) "age"6) "18"
2) 1) "1703235648454-0"2) 1) "name"2) "Bulma"3) "sex"4) "female"5) "age"6) "18"
3) 1) "1703238306386-0"2) 1) "name"2) "Android18"3) "sex"4) "female"5) "age"6) "18"

6.XTRIM - 对流进行修剪，限制长度

（1）语法格式：

XTRIM key MAXLEN [~] count

（2）参数：

  • key：队列名称
  • MAXLEN：Stream中最大消息数量（即保留的消息数量）
  • [~]：若使用了 ~ 符号，则表示限制的是消息的大小而非数量。
  • count：需要删除的消息数量

（3）示例：

# 限制MQ最多1条消息，其余删除
127.0.0.1:6379[15]> XTRIM MQ MAXLEN 1
(integer) 2
127.0.0.1:6379[15]> XRANGE MQ - +
1) 1) "1703238306386-0"2) 1) "name"2) "Android18"3) "sex"4) "female"5) "age"6) "18"

7.XREAD - 以阻塞或非阻塞方式读取一个或多个队列的消息

（1）语法格式：

XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] id [id ...]

（2）参数：

  • count：数量，默认值为10
  • milliseconds：可选，阻塞毫秒数，没有设置就是非阻塞模式
  • key：队列名
  • id：指定读取的起始位置，可以是特定的消息ID，也可以是"$"表示最新的消息，或者是"0"表示从最早的消息开始读取。

（3）示例：

127.0.0.1:6379[15]> XADD MQ * name Vegeta sex male age 18
"1703297838206-0"
127.0.0.1:6379[15]> XADD MQ * name Bulma sex female age 18
"1703297844215-0"
# 读取MQ最早的默认条消息
127.0.0.1:6379[15]> XREAD STREAMS MQ 0
1) 1) "MQ"2) 1) 1) "1703238306386-0"2) 1) "name"2) "Android18"3) "sex"4) "female"5) "age"6) "18"2) 1) "1703297838206-0"2) 1) "name"2) "Vegeta"3) "sex"4) "male"5) "age"6) "18"3) 1) "1703297844215-0"2) 1) "name"2) "Bulma"3) "sex"4) "female"5) "age"6) "18"# 读取MQ第二条消息，需指定第二条消息的ID
127.0.0.1:6379[15]> XREAD STREAMS MQ 1703297838206-0
1) 1) "MQ"2) 1) 1) "1703297844215-0"2) 1) "name"2) "Bulma"3) "sex"4) "female"5) "age"6) "18"# 读取MQ最新的一条消息，需开启阻塞，阻塞时长为10s。如果10s内未读取到消息则退出阻塞。
【客户端A】127.0.0.1:6379[15]> XREAD BLOCK 100000 STREAMS MQ $
1) 1) "MQ"2) 1) 1) "1703300894359-0"2) 1) "name"2) "Ranchi"3) "sex"4) "male"5) "age"6) "18"
(2.04s)
【客户端A】127.0.0.1:6379[15]># 另开一个终端向MQ队列中写入一条消息，阻塞读的终端就能接收到消息。
root@帅龍之龍:~# redis-cli -h 127.0.0.1 -p 6379 -a 123456
Warning: Using a password with '-a' or '-u' option on the command line interface may not be safe.
【客户端B】127.0.0.1:6379> select 15
OK
【客户端B】127.0.0.1:6379[15]> XADD MQ * name Ranchi sex male age 18
"1703300894359-0"
【客户端B】127.0.0.1:6379[15]>

（4）注意：XREAD存在消息漏读的风险，当正在处理一条消息时，又有多条消息到达，此时读取的是最新那条！

二、消费者组相关命令

消费者组将多个消费者划分到一个组中，监听同一个队列，具有消息分流、消息标示、消息确认的特点。
·消息分流：分流给组内的不同消费者，不会重复消费，反而加快消费
·消息标示：消费者组会记录最后一个被处理的消息，确保每一个消息都会被消费
·消息确认：消费者获取消息后，消息处于pending状态，然后将其存入pending-list列表，当处理完成后，通过XACK确认消息，将消息标记为已处理，然后从pending-list被移除

1.XGROUP CREATE - 创建消费者组

（1）语法格式：

XGROUP CREATE key group id|$

（2）参数：

  • key：队列名称，如果不存在就创建起始ID
  • group：消费者组名
  • id：起始ID，$代表队列中最后一条消息，0代表队列中第一条消息

（3）示例：

# 创建一个从队列第一条消息开始消费的消费者组
127.0.0.1:6379[15]> XGROUP CREATE MQ mqGroupA 0
OK
# 创建一个从队列最后一条消息开始消费的消费者组
127.0.0.1:6379[15]> XGROUP CREATE MQ mqGroupB $
OK

2.XGROUP CREATECONSUMER - 在指定的消费者组中添加消费者

（1）语法格式：

XGROUP CREATECONSUMER key group consumer

（2）参数：

  • key：队列名称，如果不存在就创建
  • group：消费者组名
  • consumer：消费者名

（3）示例：

127.0.0.1:6379[15]> XGROUP CREATECONSUMER MQ mqGroupA consumer1
(integer) 1
127.0.0.1:6379[15]> XGROUP CREATECONSUMER MQ mqGroupA consumer2
(integer) 1
127.0.0.1:6379[15]> XGROUP CREATECONSUMER MQ mqGroupA consumer3
(integer) 1

3.XINFO STREAM - 打印流信息

（1）语法格式：

XINFO STREAM key

（2）参数：

  • key：队列名称

（3）示例：

127.0.0.1:6379[15]> XINFO STREAM MQ1) "length"2) (integer) 53) "radix-tree-keys"4) (integer) 15) "radix-tree-nodes"6) (integer) 27) "last-generated-id"8) "1703300894359-0"9) "max-deleted-entry-id"
10) "1703238230846-0"
11) "entries-added"
12) (integer) 8
13) "recorded-first-entry-id"
14) "1703238306386-0"
15) "groups"
16) (integer) 2
17) "first-entry"
18) 1) "1703238306386-0"2) 1) "name"2) "Android18"3) "sex"4) "female"5) "age"6) "18"
19) "last-entry"
20) 1) "1703300894359-0"2) 1) "name"2) "Ranchi1"3) "sex"4) "male"5) "age"6) "18"

4.XINFO GROUPS - 打印消费者组的信息

（1）语法格式：

XINFO GROUPS key

（2）参数：

  • key：队列名称

（3）示例：

127.0.0.1:6379[15]> XINFO GROUPS MQ
1)  1) "name"2) "mqGroupA"3) "consumers"4) (integer) 35) "pending"6) (integer) 07) "last-delivered-id"8) "0-0"9) "entries-read"10) (nil)11) "lag"12) (integer) 5
2)  1) "name"2) "mqGroupB"3) "consumers"4) (integer) 05) "pending"6) (integer) 07) "last-delivered-id"8) "1703300894359-0"9) "entries-read"10) (nil)11) "lag"12) (integer) 0

5.XGROUP DELCONSUMER - 在指定的消费者组中删除消费者

（1）语法格式：

XGROUP DELCONSUMER key group consumer

（2）参数：

  • key：队列名称，如果不存在就创建
  • group：消费者组名
  • consumer：消费者名

（3）示例：

127.0.0.1:6379[15]> XGROUP DELCONSUMER MQ mqGroupA consumer3
(integer) 0

6.XGROUP DESTROY - 删除指定的消费者组

（1）语法格式：

XGROUP DESTROY key group

（2）参数：

  • key：队列名称，如果不存在就创建
  • group：消费者组名

（3）示例：

127.0.0.1:6379[15]> XGROUP DESTROY MQ mqGroupB
(integer) 1

7.XGROUP SETID - 为消费者组设置新的最后递送消息ID

（1）语法格式：

XGROUP SETID key group id|$

（2）参数：

  • key：队列名称，如果不存在就创建
  • group：消费者组名
  • id：起始ID，$代表队列中最后一条消息，0代表队列中第一条消息

（3）示例：

127.0.0.1:6379[15]> XGROUP CREATE MQ mqGroupB $
OK
127.0.0.1:6379[15]> XGROUP SETID MQ mqGroupB $
OK

8.XREADGROUP GROUP - 读取消费者组中的消息

（1）语法格式：

XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] id [id ...]

（2）参数：

  • group：消费者组名
  • consumer：消费者名
  • count：读取数量
  • milliseconds：阻塞毫秒数
  • key：队列名
  • id：起始ID，>代表从下一条未消费的消息开始，0代表从pending-list中第一条消息开始，其它根据指定id从pending-list中获取已消费但未确认的消息开始

（3）示例：

# 指定消费者组的消费者去读取下一条未消费的消息
127.0.0.1:6379[15]> XREADGROUP GROUP mqGroupA consumer1 COUNT 1 STREAMS MQ >
1) 1) "MQ"2) 1) 1) "1703238306386-0"2) 1) "name"2) "Android18"3) "sex"4) "female"5) "age"6) "18"
127.0.0.1:6379[15]>
127.0.0.1:6379[15]> XREADGROUP GROUP mqGroupA consumer2 COUNT 1 STREAMS MQ >
1) 1) "MQ"2) 1) 1) "1703297838206-0"2) 1) "name"2) "Vegeta"3) "sex"4) "male"5) "age"6) "18"
127.0.0.1:6379[15]>

（4）注意：若某个消费者，消费了某条消息，但是并没有处理成功时（如消费者进程宕机），这条消息可能会丢失，因为组内其他消费者不能再次消费到该消息了！

9.XPENDING - 显示待处理消息的相关信息

（1）语法格式：

XPENDING key group [[IDLE min-idle-time] start end count [consumer]]

（2）参数：

  • key：队列名
  • group：消费者组名
  • start：开始值，-表示最小值
  • end：结束值，+表示最大值
  • count：数量

（3）示例：

127.0.0.1:6379[15]> XPENDING MQ mqGroupA
1) (integer) 2 # 已读取但未处理的消息数
2) "1703238306386-0" # 起始消息ID
3) "1703297838206-0" # 结束消息ID
4) 1) 1) "consumer1"2) "1"2) 1) "consumer2"2) "1"
127.0.0.1:6379[15]> XPENDING MQ mqGroupB
1) (integer) 0
2) (nil)
3) (nil)
4) (nil)

10.XACK - 将消息标记为"已处理"

（1）语法格式：

XACK key group id [id ...]

（2）参数：

  • key：队列名
  • group：消费者组名
  • id：消息ID

（3）示例：

127.0.0.1:6379[15]> XACK MQ mqGroupA 1703238306386-0
(integer) 1
127.0.0.1:6379[15]> XPENDING MQ mqGroupA
1) (integer) 1
2) "1703297838206-0"
3) "1703297838206-0"
4) 1) 1) "consumer2"2) "1"
127.0.0.1:6379[15]>

11.XCLAIM - 转移消息的归属权

（1）语法格式：

XCLAIM key group consumer min-idle-time id [id ...] [IDLE ms] [TIME unix-time-milliseconds] [RETRYCOUNT count] [FORCE] [JUSTID] [LASTID lastid]

（2）参数：

  • key：队列名
  • group：消费者组名
  • consumer：消费者名
  • min-idle-time：从被读取到未处理的时间
  • id：消息ID

（3）示例：

# 在指定的消费者组中，将cosumer2已读取5分钟(300秒，300000毫秒)，但未处理的`1703297838206-0`消息转移给consumer1
127.0.0.1:6379[15]> XPENDING MQ mqGroupA
1) (integer) 1
2) "1703297838206-0"
3) "1703297838206-0"
4) 1) 1) "consumer2"2) "1"
127.0.0.1:6379[15]> XCLAIM MQ mqGroupA consumer1 3600000 1703297838206-0
(empty array) # 转移不成功
127.0.0.1:6379[15]> XCLAIM MQ mqGroupA consumer1 300000 1703297838206-0
1) 1) "1703297838206-0"2) 1) "name"2) "Vegeta"3) "sex"4) "male"5) "age"6) "18"
127.0.0.1:6379[15]> XPENDING MQ mqGroupA
1) (integer) 1
2) "1703297838206-0"
3) "1703297838206-0"
4) 1) 1) "consumer1"2) "1"
127.0.0.1:6379[15]> XPENDING MQ mqGroupA - + 10
1) 1) "1703297838206-0"2) "consumer1"3) (integer) 1171095 # IDLE被重置了4) (integer) 2 # 读取次数被+1

（4）说明：某个消费者读取了消息但没有处理，这时消费者宕机或重启等就会导致该消息失踪。那么就需要该消息转移给其他的消费者处理，就是消息转移。转移除了要指定ID外，还需要指定min-idle-time最小空闲时间，该值要小于消息从被读取到未处理的时间。

三、消息队列的帮助命令

（1）语法格式：

HELP XXX

（2）参数：

  • XXX：命令关键字

（3）示例：

127.0.0.1:6379[15]> help XADDXADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|id field value [field value ...]summary: Appends a new message to a stream. Creates the key if it doesn't exist.since: 5.0.0group: stream127.0.0.1:6379[15]> HELP XGROUPXGROUP (null)summary: A container for consumer groups commands.since: 5.0.0group: streamXGROUP CREATE key group id|$ [MKSTREAM] [ENTRIESREAD entries-read]summary: Creates a consumer group.since: 5.0.0group: streamXGROUP CREATECONSUMER key group consumersummary: Creates a consumer in a consumer group.since: 6.2.0group: streamXGROUP DELCONSUMER key group consumersummary: Deletes a consumer from a consumer group.since: 5.0.0group: streamXGROUP DESTROY key groupsummary: Destroys a consumer group.since: 5.0.0group: streamXGROUP HELP (null)summary: Returns helpful text about the different subcommands.since: 5.0.0group: streamXGROUP SETID key group id|$ [ENTRIESREAD entries-read]summary: Sets the last-delivered ID of a consumer group.since: 5.0.0group: stream127.0.0.1:6379[15]>

相关文章：

Redis Stream消息队列之基本语法与使用方式

前言 本文的主角是Redis Stream，它是Redis5.0版本新增加的数据结构，主要用于消息队列，提供了消息的持久化和主备复制功能，可以让任何客户端访问任何时刻的数据，并且能记住每一个客户端的访问位置，还能保证…...

编程日记 2023/12/24 6:31:56

制造行业定制软件解决方案——工业信息采集平台

摘要：针对目前企业在线检测数据信号种类繁多，缺乏统一监控人员和及时处置措施等问题。蓝鹏测控开发针对企业工业生产的在线数据的集中采集分析平台，通过该工业信息采集平台可将企业日常各种仪表设备能够得到数据进行集中分析处理存储&#xf…...

编程日记 2023/12/24 6:29:54

[python]用python实现对arxml文件的操作

目录 关键词平台说明一、背景二、方法2.1 库2.2 code 关键词 python、excel、DBC、openpyxl 平台说明 项目Valuepython版本3.6 一、背景 有时候需要批量处理arxml文件(ARXML 文件符合 AUTOSAR 4.0 标准)，但是工作量太大，阔以考虑用python。 二、方…...

编程日记 2023/12/24 6:28:53

pdf 在线编辑

https://smallpdf.com/edit-pdf#rapp 参考 https://zh.wikihow.com/%E5%B0%86%E5%9B%BE%E5%83%8F%E6%8F%92%E5%85%A5PDF...

编程日记 2023/12/24 6:27:52

自然语言处理（NLP）：理解语言，赋能未来

目录 前言1 什么是NLP2 NLP的用途3 发展历史4 NLP的基本任务4.1 词性标注（Part-of-Speech Tagging）4.2 命名实体识别（Named Entity Recognition）4.3 共指消解（Co-reference Resolution）4.4 依存关系分析&am…...

编程日记 2023/12/24 6:24:49

FastAPI使用loguru时，出现重复日志打印的解决方案

首先看图，发现每个日志都被打印了3条。其实这个和uvicorn日志打印的设计有关，在uvicorn中有多个logger，分别是uvicorn、uvicorn.error、uvicorn.access 而LOGGING默认有一个属性propagate，这个属性为True时，子日志记录…...

编程日记 2023/12/24 6:22:46

构建每个聚类的profile和deletion_mean特征

通过summarize_clusters函数构建每个聚类的protein[cluster_profile]和protein[cluster_deletion_mean]特征。目的是把extra_msa信息反映到msa中。 集成函数数据处理流程： sample_msa ->make_masked_msa -> nearest_neighbor_clusters -> summarize_clu…...

编程日记 2023/12/24 6:21:45

Milvus数据一致性介绍及选择方法

1、Milvus 时钟机制 Milvus 通过时间戳水印来保障读链路的一致性，如下图所示，在往消息队列插入数据时， Milvus 不光会为这些插入记录打上时间戳，还会不间断地插入同步时间戳，以图中同步时间戳 syncTs1 为例&#xff0…...

编程日记 2023/12/24 6:20:44

异常处理和单元测试python

一、实验题目 异常处理和单元测试 二、实验目的 了解异常的基本概念和常用异常类。掌握异常处理的格式、处理方法。掌握断言语句的作用和使用方法。了解单元测试的基本概念和作用。掌握在Python中使用测试模块进行单元测试的方法和步骤。 三、实验内容 编程实现如下功能&a…...

编程日记 2023/12/24 6:19:43

蓝牙物联网在汽车领域的应用

I、蓝牙的技术特点 ​ 1998 年 5 月，瑞典爱立信、芬兰诺基亚、日本东芝、美国IBM 和英特尔公司五家著名厂商，在联合拓展短离线通信技术的标准化活动时提出了蓝牙技术的概念。蓝牙工作在无需许可的 2.4GHz 工业频段 (SIM)之上(我国的频段范围为2400.0~248…...

编程日记 2023/12/24 6:18:42

用23种设计模式打造一个cocos creator的游戏框架----(二十二)原型模式

1、模式标准 模式名称：原型模式 模式分类：创建型 模式意图：用原型实例指定创建对象的种类，并且通过复制这些原型创建新的对象 结构图： 适用于： 1、当一个系统应该独立于它的产品创建、构成和表示时 2、…...

编程日记 2023/12/24 6:17:41

paddle 55 使用Paddle Inference部署嵌入nms的PPYoloe模型（端到端fps达到52.63）

Paddle Inference 是飞桨的原生推理库，提供服务器端的高性能推理能力。由于 Paddle Inference 能力直接基于飞桨的训练算子，因此它支持飞桨训练出的所有模型的推理。paddle平台训练出的模型转换为静态图时可以选用Paddle Inference的框架进行推理，博主以前都是将静态图转换为…...

编程日记 2023/12/24 6:16:40

自动化测试工具-Selenium：WebDriver的API/方法使用全解

我们上一篇文章介绍了Selenium的三大组件，其中介绍了WebDriver是最重要的组件。在这里，我们将看到WebDriver常用的API/方法（注：这里使用Python语言来进行演示）。 1. WebDriver创建 打开VSCode，我们首先引…...

编程日记 2023/12/24 6:15:39

如何通过蓝牙串口启动智能物联网？

1、低功耗蓝牙(BLE)介绍 BLE 技术是一种低成本、短距离、可互操作的鲁棒性无线技术，工作在免许可的 2,4 GHZ 工业、科学、医学(Industrial Scientific Medical，ISM)频段。BLE在设计之初便被定位为一种超低功耗(Ultra Low Power，ULP)无线技术&…...

编程日记 2023/12/24 6:14:38

Linux---基础操作命令

内容导航 类别内容导航机器学习机器学习算法应用场景与评价指标机器学习算法—分类机器学习算法—回归机器学习算法—聚类机器学习算法—异常检测机器学习算法—时间序列数据可视化数据可视化—折线图数据可视化—箱线图数据可视化—柱状图数据可视化—饼图、环形图、雷达图统…...

编程日记 2023/12/24 6:13:37

uniapp怎么动态渲染导航栏的title?

直接在接口请求里面写入以下： 自己要什么参数就写什么参数 本人仅供参考： this.name res.data.data[i].name; console.log(名字, res.data.data[i].name); uni.setNavigationBarTitle({title: this.name}) 效果：...

编程日记 2023/12/24 6:11:35

【机器学习】决策树

参考课程视频：https://www.icourse163.org/course/NEU-1462101162?tid1471214452 1 概述 样子： 2 分裂 2.1 分裂原则 信息增益 信息增益比 基尼指数 3 终止 & 剪枝 3.1 终止条件 无需分裂 当前节点内样本同属一类 无法分裂 当前节点内…...

编程日记 2023/12/24 6:09:33

[node] Node.js的全局对象Global

[node] Node.js的全局对象Global 什么是全局对象 & 全局变量全局对象与全局变量全局变量-- __filename全局变量-- __dirname全局函数-- setTimeout(cb, ms)全局函数-- clearTimeout(t)全局函数-- setInterval(cb, ms)全局变量-- consoleconsole 方法概览 全局变量-- proces…...

编程日记 2023/12/24 6:08:32

完整的 Meteor NPM 集成

在Meteor中，你只能使用包内的模块。你不能直接将模块与流星应用一起使用。此软件包解决了该问题 文章目录 源码下载地址安装定义软件包使用软件包在 Meteor 方法中使用 npm 模块的示例应用程序接口异步实用程序Async.runSync（函数）Meteor.sy…...

编程日记 2023/12/24 6:05:30

智能优化算法应用：基于骑手优化算法3D无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用：基于骑手优化算法3D无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用：基于骑手优化算法3D无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.骑手优化算法4.实验参数设定5.算法结果6.…...

编程日记 2023/12/24 6:04:29

解决 MATLAB 遗传算法中 exitflg=4 的问题

一、优化问题简介 以求解下述优化问题为例： P 1 : min ⁡ p ∑ k 1 K p k s . t . { ∑ k 1 K R k r e q l o g ( 1 α k ∗ p k ) ≤ B b s , ∀ k ∈ K p k ≥ 0 , ∀ k ∈ K \begin{align} {P_1:}&\mathop{\min}_{\bm{p}}{ \sum\limits_{k1}^K p_k } \no…...

编程日记 2023/12/24 6:03:28

云卷云舒：云原生业务应用成熟度模型

笔者最近学习了信通院发布的《云原生应用成熟度的评估模型》，做如下解读： 一、概述 云原生业务应用成熟度模型从企业业务应用基础设施域、应用研发域以及服务治理域等三个能力域二十个过程域综合评估企业业务应用在弹性、高可用、自愈性、可观测性以及…...

编程日记 2023/12/24 6:02:27

STM32的以太网外设+PHY（LAN8720）使用详解（5）：MAC及DMA配置

0 工具准备 1.野火 stm32f407霸天虎开发板 2.LAN8720数据手册 3.STM32F4xx中文参考手册1 MAC及DMA配置 1.1 使能ETH时钟 stm32的ETH外设挂载在AHB1总线上，位于RCC_AHB1ENR的bit25-bit27： 相关语句如下： RCC_AHB1PeriphClockCmd(RCC_AHB1…...

编程日记 2023/12/24 6:00:25

GitHub、Gitee、Gitlab共用一个SSH密钥配置

目录 1. 说明2. 生成ssh2-1. 设置全局邮箱和用户名2-2. 生成全局ssh 3. Github、Gitee配置ssh3-1. Github配置3-2. Gitee配置 1. 说明 由于我的Github、Gitee、Gitlab用的邮箱不同，向不同的平台提交代码时都需要验证密码，非常麻烦所以配置了一个共用的S…...

编程日记 2023/12/24 5:57:20

ClickHouse(19)ClickHouse集成Hive表引擎详细解析

文章目录 Hive集成表引擎创建表使用示例如何使用HDFS文件系统的本地缓存查询 ORC 输入格式的Hive 表在 Hive 中建表在 ClickHouse 中建表 查询 Parquest 输入格式的Hive 表在 Hive 中建表在 ClickHouse 中建表 查询文本输入格式的Hive表在Hive 中建表在 ClickHouse 中建表 资料…...

编程日记 2023/12/24 5:56:20

用C求斐波那契数列-----(C每日一编程)

斐波那契数列: 斐波那契数列是指这样一个数列：1，1，2，3，5，8，13，21，34，55，89……这个数列从第3项开始 ，每一项都等于前两项之和。 递推…...

编程日记 2023/12/24 5:55:19

在Jetpack Compose中使用ExoPlayer实现直播流和音频均衡器

在Jetpack Compose中使用ExoPlayer实现直播流和音频均衡器 背景 ExoPlayer与Media3的能力结合，为Android应用程序播放多媒体内容提供了强大的解决方案。在本教程中，我们将介绍如何设置带有Media3的ExoPlayer来支持使用M3U8 URL进行直播流。此外&#x…...

编程日记 2023/12/24 5:54:18

持续集成交付CICD：Jira 远程触发 Jenkins 实现更新 GitLab 分支

目录 一、实验 1.环境 2.GitLab 查看项目 3.Jira新建模块 4. Jira 通过Webhook 触发Jenkins流水线 3.Jira 远程触发 Jenkins 实现更新 GitLab 分支 二、问题 1.Jira 配置网络钩子失败 2. Jira 远程触发Jenkins 报错 一、实验 1.环境 （1）主机 …...

编程日记 2023/12/24 5:52:16

基于SSM的面向TCP_IP的网络互联实验平台

文章目录 项目介绍主要功能截图：部分代码展示设计总结项目获取方式🍅 作者主页：超级无敌暴龙战士塔塔开 🍅 简介：Java领域优质创作者🏆、 简历模板、学习资料、面试题库【关注我，都给你】 🍅文末获取源码联系🍅 项目介绍 基于SSM的面向TCP和IP的网络互联实验平台…...

编程日记 2023/12/24 5:51:15

【IDEA】try-catch自动生成中修改catch的内容

编辑器 --> 文件和代码模板 --> 代码 --> Catch Statement Body...

编程日记 2023/12/24 5:50:14

2024 十大AI预测

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗？订阅我们的简报，深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同，从行业内部的深度分析和实用指南中受益。不要错过这个机会，成为AI领…...

编程日记 2023/12/24 5:49:13

【Linux基础开发工具】gcc/g++使用make/Makefile

目录 前言 gcc/g的使用 1. 语言的发展 1.1 语言和编译器自举的过程 1.2 程序翻译的过程： 2. 动静态库的理解 Linux项目自动化构建工具-make/makefile 1. 快速上手使用 2. makefile/make执行顺序的理解 前言 了解完vim编辑器的使用，接下来就可以尝…...

编程日记 2023/12/24 5:47:12

Windows Nginx版本升级

记录windows系统上nginx版本从1.22.1直接升级到1.25.3，全程一步到位！ nginx官网: https://nginx.org/ C:\Windows\system32>cd C:\nginx# 查看当前nginx版本C:\nginx>nginx -v nginx version: nginx/1.22.1# 停止nginx服务C:\nginx>net stop ng…...

编程日记 2023/12/24 5:46:11

kubernetes集群 应用实践 kafka部署

kubernetes集群 应用实践 kafka部署 零.1、环境说明 零.2、kafka架构说明 zookeeper在kafka集群中的作用 一、Broker注册 二、Topic注册 三、Topic Partition选主 四、生产者负载均衡 五、消费者负载均衡 一、持久化存储资源准备 1.1 创建共享目录 [rootnfsserver ~]# mkdir -…...

编程日记 2023/12/24 5:45:10

Featured Based知识蒸馏及代码(3): Focal and Global Knowledge (FGD)

文章目录 1. 摘要2. Focal and Global 蒸馏的原理2.1 常规的feature based蒸馏算法2.2 Focal Distillation2.3 Global Distillation2.4 total loss3. 实验完整代码论文： htt...

编程日记 2023/12/24 5:44:09

CentOs 安装MySQL

1、拉取安装包 wget --no-check-certificate dev.mysql.com/get/mysql-community-release-el6-5.noarch.rpm 成功拉取 2、安装 yum install mysql-community-release-el6-5.noarch.rpm 过程中可能需要你同意一些东西，y 即可 然后稍微检查一下 yum repolist enabled…...

编程日记 2023/12/24 5:43:07

基于Java (spring-boot)的在线考试管理系统

一、项目介绍 系统功能说明 1、系统共有管理员、老师、学生三个角色，管理员拥有系统最高权限。 2、老师拥有考试管理、题库管理、成绩管理、学生管理四个模块。 3、学生可以参与考试、查看成绩、试题练习、留言等功能 二、作品包含 三、项目技术 后端语言&…...

编程日记 2023/12/24 5:42:06

5. 结构型模式 - 外观模式

亦称： Facade 意图 外观模式是一种结构型设计模式， 能为程序库、 框架或其他复杂类提供一个简单的接口 问题 假设你必须在代码中使用某个复杂的库或框架中的众多对象。 正常情况下， 你需要负责所有对象的初始化工作、 管理其依赖关系并按正确…...

编程日记 2023/12/24 5:39:04

微服务之配置中心与服务跟踪

zookeeper 配置中心 实现的架构图如下所示，采取数据加载到内存方式解决高效获取的问题，借助 zookeeper 的节点监听机制来实现实时感知。 配置中心数据分类 事件调度（kafka） 消息服务和事件的统一调度，常用用 kafka …...

编程日记 2023/12/24 5:38:03

链表 典型习题

160 相交链表：遍历，统计是否出现过 /*** Definition for singly-linked list.* struct ListNode {* int val;* ListNode *next;* ListNode(int x) : val(x), next(NULL) {}* };*/ class Solution { public:ListNode *getIntersectionNode(L…...

编程日记 2023/12/24 5:37:02

面试题：JVM 对锁都进行了哪些优化？

文章目录 锁优化自旋锁和自适应自旋锁消除锁粗化逃逸分析方法逃逸线程逃逸通过逃逸分析，编译器对代码的优化 锁优化 jvm 在加锁的过程中，会采用自旋、自适应、锁消除、锁粗化等优化手段来提升代码执行效率。 自旋锁和自适应自旋 现在大多的处理器都是…...

编程日记 2023/12/24 5:30:56

SSM整合实战（Spring、SpringMVC、MyBatis）

五、SSM整合实战 目录 一、SSM整合理解 1. 什么是SSM整合？2. SSM整合核心理解五连问！ 2.1 SSM整合涉及几个IoC容器？2.2 每个IoC容器盛放哪些组件？2.3 IoC容器之间是什么关系？2.4 需要几个配置文件和对应IoC容器关系&…...

编程日记 2023/12/24 5:29:54

QT调用外部exe及无终端弹窗的解决方案、并实现进程输出信息获取

博主使用QT调用外部exe程序&#xff0c;外部exe程序有printf输出&#xff0c;起初使用的是C语言中的system()方法&#xff0c;但在笔记本上有概率出现终端窗口一闪而过的情况&#xff0c;后修改了调用方案。 1. QT调用外部exe 使用QT中的QProcess方法 #include <QProcess…...

编程日记 2023/12/24 5:26:51

大语言模型的三种主要架构 Decoder-Only、Encoder-Only、Encoder-Decoder

现代大型语言模型&#xff08;LLM&#xff09;的演变进化树&#xff0c;如下图&#xff1a; https://arxiv.org/pdf/2304.13712.pdf 基于 Transformer 模型以非灰色显示&#xff1a; decoder-only 模型在蓝色分支&#xff0c; encoder-only 模型在粉色分支&#xff0c; encod…...

编程日记 2023/12/24 5:25:51

【MySQL】外连接 where 和 on 的区别

力扣题 1、题目地址 1158. 市场分析 I 2、模拟表 User Column NameTypeuser_idintjoin_datedatefavorite_brandvarchar user_id 是此表主键&#xff08;具有唯一值的列&#xff09;。表中描述了购物网站的用户信息&#xff0c;用户可以在此网站上进行商品买卖。 Orders…...

编程日记 2023/12/24 5:22:49

【优化】XXLJOB修改为使用虚拟线程

【优化】XXLJOB修改为使用虚拟线程 新建这几个目录 类&#xff0c; 去找项目对应的xxljob的源码 主要是将 new Thread 改为 虚拟线程 Thread.ofVirtual().name("VT").unstarted 以下代码是 xxljob 2.3.0版本 举一反三 去修改对应版本的代码 <!-- 定…...

编程日记 2023/12/24 5:19:46

金蝶Apusic应用服务器 loadTree JNDI注入漏洞复现(QVD-2023-48297)

0x01 产品简介 金蝶Apusic应用服务器是一款企业级应用服务器，支持Java EE技术，适用于各种商业环境。 0x02 漏洞概述 由于金蝶Apusic应用服务器权限验证不当，导致攻击者可以向loadTree接口执行JNDI注入，造成远程代码执行漏洞。利用该漏洞需低版本JDK。（漏洞比较旧，8月份…...

编程日记 2023/12/24 5:17:44

PromptNER: Prompt Locating and Typing for Named Entity Recognition

原文链接&#xff1a; https://aclanthology.org/2023.acl-long.698.pdf ACL 2023 介绍 问题 目前将prompt方法应用在ner中主要有两种方法&#xff1a;对枚举的span类型进行预测&#xff0c;或者通过构建特殊的prompt来对实体进行定位。但作者认为这些方法存在以下问题&#xf…...

编程日记 2023/12/24 5:13:41

QT编写应用的界面自适应分辨率的解决方案

博主在工作机上完成QT软件开发&#xff08;控件大小与字体大小比例正常&#xff09;&#xff0c;部署到客户机后&#xff0c;发现控件大小与字体大小比例失调&#xff0c;具体表现为控件装不下字体&#xff0c;即字体显示不全&#xff0c;推测是软件不能自适应分辨率导致的。 文…...

编程日记 2023/12/24 5:12:40

Kubernetes pod ip 暴露

1. k8s pod 和 service 网络暴露 借助 iptables 的路由转发功能&#xff0c;打通k8s集群内的pod和service网络&#xff0c;与外部网络联通 # 查看集群的 pod 网段和 service 网段 kubectl -n kube-system describe cm kubeadm-config networking:dnsDomain: cluster.localpod…...

编程日记 2023/12/24 5:10:38