消息 队列rabbitmq
MQTT(消息队列遥测传输)
Message Queuing Telemetry Transport -- 消息队列遥测传输协议 MQTT(Message Queuing Telemetry Transport, 消息队列遥测传输协议)，是一种基于发布/订阅(publish/subscribe)模式的"轻量级"通讯协议，该协议构 ......
单调栈和单调队列学习/复习笔记
模板 P5788 【模板】单调栈 目的： 解决一个序列任意的一个数前/后第一个大于/小于他的数的问题。 实现： 首先先把输入的数组读进来 从后向前遍历，手写一个栈，对于扫到的每个元素都与栈顶元素进行比较。若扫到的元素大于等于栈顶元素（由于是手写栈，需要判断栈内是否还有元素，若没有直接加入元素即可）， ......
队列的API
2023.10.6 1.poll，peek，element 相同点：都是返回队列首个元素 不同点： poll：将首个元素从队列中弹出，如果队列是空的，就返回null peek：查看首个元素，不会移除首个元素，如果队列是空的就返回null element：查看首个元素，不会移除首个元素，如果队列是空的 ......
odoo16开启gevent多进程，提高性能及启用消息推送
原文地址： https://www.odooai.cn/blog/odoo-install-deploy-6/odoo-gevent-web-socket-boost-setup-286odoo16有一个最大的性能提升，就是从longpolling改成了web socket的方式来推送消息。这个改进 ......
有点奇葩的消息——CEO 2 个月之前也离职了
这个消息还是有点奇葩的。 在找工作一段时间后，有原公司的同事联系了下互相通报了下各自的情况。 如有看过：北美 2023 被裁员的感悟 这篇文章的大致都知道公司在4个月前，也就是2023年6月份的时候进行了大规模的裁员，公司也只保留了最低的运营水平。 但实在没有想到的是公司的原 CEO，居然在今年的 ......
RabbitMQ 集群搭建和仲裁队列的使用
RabbitMQ 是基于 Erlang 语言开发的，该语言天然支持集群分布式模式，因此部署 RabbitMQ 集群非常简单。 RabbitMQ 的集群部署有两种模式： 普通集群：又称为标准集群，是一种分布式集群，将队列分散到集群的各个节点，提高整个集群的并发能力。 镜像集群：在普通集群的基础上，添加 ......
04_猫狗队列
猫狗队列 【题目】 宠物、狗和猫的类如下： public class Pet { private String type; public Pet(String type) { this.type = type; } public String getPetType() { return this.t ......
RabbitMQ 死信交换机、延迟队列、惰性队列
如果一个队列设置了死信交换机，该队列的消息就有了极大的可靠性保障，当出现以下情况时，消息就会投递到死信交换机中： 队列中的消息在被消费者处理后，抛出异常，返回了 nack 或者 reject 如果队列设置了 ttl 或者消息本身设置了 ttl ，消息因为超时而未消费 队列容量已经满了，后续发来的消息 ......
【中秋国庆不断更】HarmonyOS对通知类消息的管理与发布通知（下）
【中秋国庆不断更】HarmonyOS对通知类消息的管理与发布通知（下） 一、发布进度条类型通知 进度条通知也是常见的通知类型，主要应用于文件下载、事务处理进度显示。HarmonyOS提供了进度条模板，发布通知应用设置好进度条模板的属性值，如模板名、模板数据，通过通知子系统发送到通知栏显示。 目前系统 ......
消息总线 —— SpringCloud Bus
Bus 简介 Spring Cloud Bus 是 Spring Cloud 体系内的消息总线，支持 RabbitMQ 和 Kafka 两种消息中间件。所谓消息总线，简单理解就是一个消息中心，众多微服务实例都可以连接到总线上，实例可以往消息中心发送或接收信息，例如：实例 A 发送一条消息到总线上，总 ......
Celery将任务分发到不同的队列，交给不同的Worker处理
https://docs.celeryq.dev/en/stable/userguide/routing.html#routing-tasks https://blog.csdn.net/wanglei_storage/article/details/130029916 https://www.cn ......
RabbitMQ 消息发送和消费的可靠性保障
在一些比较重要的场景中，我们必须要保障 RabbitMQ 消息的可靠性，也就是发送给 rabbitmq 的消息必须最终成功，消费者接收消息进行处理也必须最终成功。即使是中间失败了，也必须要有其它保障措施，哪怕最后进行人工进行干预处理。 消息出现丢失的场景主要有： 发送消息时丢失：比如消息发送到交换机 ......
如何在Linux关闭前向其他系统用户发送自定义消息
作为一名系统管理员，在你关闭服务器之前，你也许想要发送一条消息来警告他们系统将要关闭。默认上，shutdown命令会给其他系统用户广播信息。更多技术干货详见www.linuxprobe.com ......
消息驱动 —— SpringCloud Stream
Stream 简介 Spring Cloud Stream 是用于构建消息驱动的微服务应用程序的框架，提供了多种中间件的合理配置 Spring Cloud Stream 包含以下核心概念： Destination Binders：目标绑定器，目标指的是 Kafka 或者 RabbitMQ，绑定器就是 ......
[数据结构和算法] 堆/优先队列的实现
预备知识： 完全二叉树可以用数组表示： 从下标0开始存储数据：左子节点 = 2 * 父节点 + 1，右子节点 = 2 * 父节点 + 2； 从下标1开始存储数据：左子结点 = 2 * 父节点，右子节点= 2 * 父节点 + 1； 堆： 大根堆：父节点的值大于等于左右子节点的值； 小根堆：父节点的值小 ......
【数据结构】2.栈和队列
1.栈 1.1栈的抽象父类 #pragma once template<class T> class Stack { public: // 析构函数 virtual ~Stack() {} // 栈是否为空 virtual bool empty() const = 0; // 栈的大小 virtua ......
FreeRTOS 原理 --- 队列
队列是任务到任务、任务到中断、中断到任务数据交流的一种机制（固定长度消息传递）。 队列的优点： 不同任务之间的读写队列操作是互斥的（通过关中断实现） 读写队列由阻塞唤醒机制，阻塞的任务不抢占CPU资源（比如读队列，发现队列空，阻塞当前任务，除非其他任务有写队列，否则当前任务不再占用CPU资源） 队列 ......
【中秋国庆不断更】HarmonyOS对通知类消息的管理与发布通知（上）
【中秋国庆不断更】HarmonyOS对通知类消息的管理与发布通知（上） 一、 通知概述 通知简介 应用可以通过通知接口发送通知消息，终端用户可以通过通知栏查看通知内容，也可以点击通知来打开应用。 通知常见的使用场景： ● 显示接收到的短消息、即时消息等。 ● 显示应用的推送消息，如广告、版本 ......
配置标题消息
1.说明 通常使用以下3个标题信息参数。 header参数：用来设置当用户登录设备时在终端上显示的标题信息。 login参数：指定用户在登录设备认证过程中激活终端连接时显示的标题信息。 shell参数：指定当用户成功登录设备并已经建立会话时显示的标题信息。 如果header的内容是字符串，用head ......
消息的消费组配置、堆积总结
一、Azure EventHub1.1、消费客户端负载均衡 引用包：Azure.Messaging.EventHubs；EventHubConsumerClient简单消费；不能持久化保存所有权\检查点，做负载均衡；需要自定义实现 EventProcessor<TPartition>，如通过Redi ......
U362815 GSEP 5级样题 小杨的队列
GSEP 5级样题 小杨的队列 题目描述 小杨的班级里共有 N 名同学，学号从 0 至 N - 1。 某节课上，老师要求同学们进行列队。具体来说，老师会依次点名 $M$ 名同学，让他们加入队伍。每名新入队的同学需要先站到队伍末尾（刚开始队伍里一个人都没有，所以第一个入队的同学只需要站好即可），随后， ......
多重背包单调队列优化
引用自：动态规划-背包问题(01背包、完全背包、多重背包) #include<cstdio> #include<algorithm> #include<cstring> using namespace std; const int maxn = 100005; int n, m, cnt; int ......
企微消息接口
需求背景：希望将业务系统收到的消息推送给企微中的某个成员。 大致流程： 1）企微后台注册self-built应用，https://work.weixin.qq.com/ 进入App配置页，可以得到AgentID、Secret。在最下方可以配置Trusted IP。 需要注意的是，配置Trusted ......
使用链表模拟队列和栈
使用链表模拟队列 案例1 // 创建节点类 public class Node { int n; Node next; } // 编写方法 public class Queue { Node head = new Node(); Node last = new Node(); private int ......
使用数组模拟队列和栈
使用数组模拟队列 案例1 public class Queue { private int[] num= new int[5]; private int len=0; public int size(){ return this.len; } //添加 public int add(int n){ ......
栈和队列
$$\texttt{栈}$$ 栈(stack)，一种后进先出(last in first out，LIFO)的数据结构，主要有三种操作：压入一个元素到栈顶(push(x))，弹出栈顶的元素(pop())，访问栈顶元素(top())，当然也有询问大小(size())和返回是否为空(empty())。 ......
hmac：Python密码消息签名
# 前言 HMAC算法可以用于验证信息的完整性，这些信息可能在应用之间传递，或者存储在一个可能有安全威胁的地方。 其基本思路：生成实际数据的一个密码[散列](https://so.csdn.net/so/search?q=%E6%95%A3%E5%88%97&spm=1001.2101.3001.7 ......
安装Rabbitmq
1、查看系统版本 uname -a，centos7需要下载el7版本的安装包 2、下载对应版本的erlang、socat、rabbitmq的rpm安装包，下载地址如下： 1）https://github.com/rabbitmq/erlang-rpm/releases 2）http://www.rp ......
rabbitmq快速入门
镜像启动命令 docker run \ -e RABBITMQ_DEFAULT_USER=root \ -e RABBITMQ_DEFAULT_PASS=123456 \ --name mq \ --hostname mq1 \ -p 15672:15672 \ -p 5672:5672 \ -d ......