死信 队列rocketmq消息
RocketMQ为什么要保证订阅关系一致
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：保证订阅关系一致。 订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。 如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 1 订阅关系演示 首先我们展示正确 ......
基础数据结构：单调栈、单调队列
1、单调栈 以AcWing.830为例， 给定一个长度为N的整数数列，输出每个数左边第一个比它小的数，如果不存在则输出−1。 输入格式第一行包含整数N，表示数列长度。 第二行包含N个整数，表示整数数列。 输出格式共一行，包含N个整数，其中第i个数表示第i个数的左边第一个比它小的数，如果不存在则输出− ......
阻塞队列
什么是阻塞队列 阻塞队列是一种特殊的队列，它支持线程安全并发操作的同时提供了阻塞操作功能。在阻塞队列中，当队列为空时，从队列中取元素的操作将被阻塞，而当队列已满时，往队列中放元素的操作也会被阻塞。 阻塞队列的应用场景 阻塞队列常用于生产者和消费者的场景，生产者是向队列里添加元素的线程，消费者是从队列 ......
RabbitMQ消息丢失的场景，MQ消息丢失解决方案
第一种：（生产者）生产者弄丢了数据。生产者将数据发送到 RabbitMQ 的时候，可能数据就在半路给搞丢了，因为网络问题啥的，都有可能。 第二种：（服务端）RabbitMQ 弄丢了数据。MQ还没有持久化自己挂了 第三种：（消费者）消费端弄丢了数据。刚消费到，还没处理，结果进程挂了，比如重启了。 1. ......
小程序订阅消息（服务通知）实现 wx.requestSubscribeMessage
第一步：根据官方文来，先在微信公众平台登录小程序后台配置模板，获取模板id：，这块的模版可以在公共模版库里选。也可以新申请，但是需要3-7天才能出审核结果。 第二步，获取下发权限在获取下发权限之前，需要先获取小程序code和订阅消息的模板id给服务端，以便后台人员进行服务端配置 // 这里是获取下发 ......
RabbitMq DLX 实现延迟队列
我们可以把死信队列就当成延迟队列。 具体来说是这样： 假如一条消息需要延迟 30 分钟执行，我们就设置这条消息的有效期为 30 分钟，同时为这条消息配置死信交换机和死信 routing_key，并且不为这个消息队列设置消费者，那么 30 分钟后，这条消息由于没有被消费者消费而进入死信队列，此时我们有 ......
SpringBoot之实现Web消息实时消息推送
目录1 实时消息推送1.1 消息推送1.2 准备sql1.3 短轮询1.4 长轮询1.4.1 简介1.4.2 代码示例1.5 iframe流1.6 SSE1.6.1 简介1.6.2 与 WebSocket 区别1.6.3 代码示例1.7 MQTT1.7.1 简介1.7.2 为什么要用 MQTT协议1 ......
【RocketMQ】RocketMQ存储结构设计
CommitLog 生产者向Broker发送的消息，会以顺序写的方式，写入CommitLog文件，CommitLog文件的根目录由配置参数storePathRootDir决定，默认每一个CommitLog的文件大小为1G，如果文件写满会新建一个CommitLog文件，以该文件中第一条消息的偏移量为文 ......
07_用队列实现栈
用队列实现栈 【题目】请你仅使用两个队列实现一个后入先出（LIFO）的栈，并支持普通栈的全部四种操作（push、top、pop 和 empty）。对应于leetcode 225题 实现 MyStack 类： void push(int x) 将元素 x 压入栈顶。 int pop() 移除并返回栈顶 ......
基于订阅号开发属于自己的微信消息通知
准备工作 订阅号：1个，可以申请一个测试（https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login），一般不被举报是不会过期的 服务器：1个 步骤 前置工作 保存测试号信息 appID 和 appsecret 用微信扫码关注测试号的 ......
头歌-03 - 队列
第一关 #include <stdio.h> #include <stdlib.h> #include "SeqQueue.h" SeqQueue* SQ_Create(int maxlen) // 创建顺序队列, 队列最多存储maxlen个队列元素。 { SeqQueue* sq=(SeqQueu ......
数据结构之队列（一般队列）
1. 什么是队列？ 队列是一种特殊的线性表，一般只允许在队列的两端进行操作，队列前端进行删除操作，队列的末尾进行添加操作（双向队列的前端、末尾都可以进行删除、添加操作）。 队列可以用数组或链表实现。主要有两个指针：一个front指向队首元素，一个rear指向队尾元素。 2. 队列常见操作 队列常用的 ......
Skyapn-Dotnet源码 推送消息到远程服务器
以源码中 sqlserver 为例 var context = _tracingContext.CreateExitSegmentContext(ResolveOperationName(sqlCommand), _peerFormatter.GetDbPeer(sqlCommand.Connect ......
栈和队列
栈 栈（\(\text {stack}\)）是一种后进先出（\(\text {Last In First Out,LIFO}\)）的线性表，顾名思义，后入栈的元素反而先出栈，其限制是只能在一端插入与删除， 就像下面这样，只有一端有开口，另一端则是封死的。 \[\large\text {栈顶} \be ......
【多线程笔记】多线程处理队列数据
using System.Collections.Concurrent; using System.Diagnostics; { int threadCount = 20; List<Task> tasks = new List<Task>(); ConcurrentQueue<int> queue ......
使用微信公众号-消息模版推送ZABBIX告警
zabbix 布署实践【6 使用微信公众号-消息模版推送告警】 使用这个服务的前提是，你必须要有一个微信订阅号，或者公众号，并且是通过认证的号 因为认证过后的号才有模版消息和获取用户openid等信息的权限 ，如下，登录微信公众号的登录页后，底下有个接口权限的展示 我们可以理解为它类传于邮件发送告警 ......
Error while loading conda entry point: conda-libmamba-solver (libarchive.so.19: cannot open shared object file: No such file or directory) 报错消息解决方法
本人使用 centos:7.6.1810 及 Miniconda3-py311_23.5.2-0-Linux-x86_64 默认状态下应该没有这个问题。 当在使用conda下载包时，如果不小心更新了涉及conda-libmamba-solver 和 libarchive的包，就可能会导致这个报错消息 ......
通过机器人发送消息到钉钉群
1、在钉钉群中创建一个机器人，获取机器人的 Webhook 地址。可以参考钉钉官方文档来创建机器人并获取 Webhook 地址。 2、使用 Go 语言的 HTTP 请求库发送消息到 Webhook 地址。可以使用标准库的包net/http来发送 HTTP POST 请求。 3、构建要发送的消息内容， ......
RocketMQ 中订阅关系 按照业务分类合理拆分主题
小结： 1、 流式操作语义 Apache RocketMQ 基于队列的存储模型可确保消息从任意位点读取任意数量的消息，以此实现类似聚合读取、回溯读取等特性，这些特性是RabbitMQ、ActiveMQ等非队列存储模型不具备的。 2、 Apache RocketMQ 队列模型和Kafka的分区（Par ......
java实现 微信公众号推送消息 ，cv 就可运行！！！
一，注册公众号 1，官网地址：申请测试公众号 地址： 微信公众平台 (qq.com) 文档地址：微信开放文档 (qq.com) 2，注册后可以查看自己的appId 和 appsecret 3，创建模板 请注意： 1、测试模板的模板ID仅用于测试，不能用来给正式帐号发送模板消息 2、为方便测试，测试模 ......