activemq gt rabbitmq rocketmq
<学习笔记> 网络流
最大流 code queue<int> q; int dep[N],cur[N]; int bfs(){ memset(dep,0,sizeof(dep)); q.push(st); dep[st]=1; while(!q.empty()){ int x=q.front(); q.pop(); fo ......
一、Spring学习 : 容器---->BeanFactory+ApplicationContext
BeanFactory 接口 是什么？ 先来看我们的boot项目启动类的run方法 public static ConfigurableApplicationContext run(Class<?> primarySource, String... args) { return run(new Cl ......
DMA传输数据（M->P）
前言 上文讨论了利用DMA将数据从一个存储器搬运到另一个存储器，本文讨论将数据从M->P。将数据从数组转移到串口外设并发送出去。 代码 void MYDMA_Init(DMA_Stream_TypeDef *DMA_Streamx,u32 chx,uint32_t par,u32 mar,u16 n ......
RabbitMQ 延迟消息的实现——延迟消息插件
步骤： 1. 把资料中的 rabbitmq_delayed_message_exchange-3.9.0.ez 复制到docker的mq容器的插件目录 2. 执行命令 docker exec -it mq rabbitmq-plugins enable rabbitmq_delayed_messag ......
RabbitMQ高可用集群的搭建部署（Centos7）
高可用集群架构 节点域名 操作系统 RabbitMQ版本 Erlang版本 iamdemo.tp-link.com Centos7.9 3.8.28 23.3-2 iamdemo2.tp-link.com Centos7.9 3.8.28 23.3-2 iamdemo3.tp-link.com Ce ......
RabbitMQ 延迟消息的实现——死信交换机（不推荐）
生产者给MQ发送 带过期时间的消息： @GetMapping("/mq07")public void sendTTLMessage(){ //第四个参数：后置消息处理器。用后置消息处理器给消息加过期时间 rabbitTemplate.convertAndSend("simple.direct", " ......
RabbitMQ 消费者可靠性——业务幂等性
如何保证业务是幂等的？ 方案一： 生产者、消费者都配置上 setCreateMessageIds(true)。配好后，生产者给MQ发消息，消息就会带上自动生成的 id。将来消费者拿到消息后，就可以获取到 id，把 id保存起来 做唯一匹配 代码示例： package com.itheima;impo ......
static_cast<>
使用 static_cast 的好处主要有以下几点： 增强类型安全：static_cast 是一种显式的类型转换，它要求源类型和目标类型在某种程度上是兼容的。如果尝试进行非法的转换（例如，将 int* 转换为 char*），编译器会报错1。这有助于防止类型错误。 提高代码可读性：static_cas ......
RabbitMQ避免重复消费
在Java中，可以使用消息队列来实现消息的异步处理，其中常用的消息队列有 RabbitMQ、ActiveMQ、Kafka 等。 什么是幂等性？ 幂等性是指无论操作执行多少次，都是得到相同的结果，而不会产生其他副作用。 在rabbitMQ中 什么是消息重复消费？ 同一条消息在MQ中被消费多次 出现重复 ......
Span<T> 的性能优势
内存效率： 由于 Span<T> 可以直接引用内存中的数据，无需额外的内存分配，因此它在内存效率上非常高。 减少垃圾回收： 由于不需要创建临时对象，Span<T> 可以显著减少垃圾回收的压力，尤其对于大型数据集来说。 并行性： Span<T> 可以在多线程环境下高效地进行操作，因为它可以避免数据竞争 ......
RabbitMQ 消费者可靠性——失败重试机制
效果： 消费者抛异常后，会本地重试，如果本地重试次数达到最大重试次数之后，直接给队列返回reject，队列收到后就会丢弃该消息，也就是策略的第一种 但就这样把删了不太好，所以有了失败消息处理策略 第二种 ImmediateRequeueMessageRecoverer：消费者抛异常后，会本地重试，如 ......
RabbitMQ 消费者可靠性——消费者确认
代码示例： 在消费者的 appplication.yml 文件中加入配置： spring: rabbitmq: listener: simple: acknowledge-mode: auto ......
使用PyUIC将.ui文件转换为.py文件时出现 <?xml version="1.0" encoding="UTF-8"?> ^ SyntaxError: invalid syntax
弄好相应第三方库在Pycharm中的配置后，完成窗口界面后生成.ui文件 使用PyUIC将.ui文件转换为.py文件时出现 <?xml version="1.0" encoding="UTF-8"?> ^ SyntaxError: invalid syntax 查了网上方法没解决，最后将PyUIC配 ......
RabbitMQ 生产者可靠性——生产者确认原理
生产者确认更加注重 消息发送失败时该怎么办 消息发送失败 采用的是确认机制（有两种确认机制：Publisher Confirm 和 Publisher Return） ......
RabbitMQ 生产者可靠性——生产者重连
我们配置的这个失败后的重连机制仅仅是发送者连接MQ失败 的 连接失败重试，如果消息发送抛出异常时不会重试，因为它只是连接失败的重试，不是消息发送的重试 spring: rabbitmq: host: 192.168.88.130 port: 5672 virtual-host: /hmall use ......
RabbitMQ 消息转换器
代码示例： 1. 引入依赖 <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId></dependency> 2. 在启动类中创建Bean package ......
RabbitMQ Java代码声明队列和交换机（方法二）
代码示例：创建一个Direct交换机，与两个队列绑定（direct.queue1、direct.queue2） 既是消费者，又可以创建交换机和队列，以及交换机与队列的 RoutingKey @RabbitListener(bindings = @QueueBinding( value = @Queu ......
RabbitMQ Java代码声明队列和交换机（方法一）
交换机和队列的声明一般写在消费者模块里 代码示例： package com.itheima.config_RabbitMQ;import org.springframework.amqp.core.*;import org.springframework.context.annotation.Bea ......
RabbitMQ Topic交换机
代码示例： 1. 新建两个队列 2. 创建交换机，名字叫 hmall.topic，类型选择 topic 3. hmall.topic 交换机绑定第一步的两个队列，绑定过程中填写 RoutingKey 4. 编写消费者代码监听这两个队列 @RabbitListener(queues = "topic. ......
RabbitMQ Direct交换机
代码示例： 1. 交换机绑定了两个队列，并给它们设置了RoutingKey 2. publisher 发送者给 Direct 交换机发消息时，第二个参数指定 RoutingKey： @GetMapping("/mq03")public void mq03(){ String exchangeName ......
RabbitMQ 发送消息到交换机
发送消息到交换机的代码： @GetMapping("/mq02")//发送消息给交换机public void mq02(){ String exchangeName = "hmall.fanout"; String msg = "hello, 每个人"; //三个参数：交换机名称、RoutingKe ......
RabbitMQ Fanout交换机
容易搞混的点： 1. 假如 publisher 给Fanout交换机发送了一条消息，那么Fanout交换机会给每一个绑定到它身上的队列都发送这条消息，也就是说有多少个队列跟它绑定了，这条消息就有几份，每个队列都收到一份。 2. 假如一个队列绑定了多个消费者，那么该队列在给消费者投递消息时就是轮询，一 ......
<金融心理学>读书笔记一
关于“市场走在前面”的一些想法 1、股票市场经常提前反映经济的转折和好坏，债券市场也是，这其中的道理是 股票市场其实也是人的市场，人们买卖股票造成了股市的涨跌，人对未来经济的预期，会提前反馈在股价上，这是导致股市走在经济前面的主要原因，所以人的预期非常重要 但是并不是所有的人都很重要，决定股价走势的 ......
rabbitmq的推(push)拉(pull)模式介绍及代码实现
在rabbitmq中有两种消息处理的模式，一种是推模式/订阅模式/投递模式（也叫push模式），消费者调用channel.basicConsume方法订阅队列后，由RabbitMQ主动将消息推送给订阅队列的消费者；另一种是拉模式/检索模式（也叫pull模式），需要消费者调用channel.basic ......
执行SQL 获取一个Model 集合 List<Model>
/// <summary> /// 获取最新的24条数据 /// </summary> /// <returns></returns> public List<WeldResultModel> GetListByLase24() { var sql = @"SELECT TOP 24 * FROM ......
RabbitMQ work模型
默认情况下，MQ队列如果绑定了多个消费者，那么队列在投递消息时就是轮询，一人投递一个（并且一条消息只能投递给监听该队列的某一个消费者） 在一个MQ队列上绑定多个消费者的目的是加快队列中消息的处理效率，防止队列中消息的堆积问题。 注：要在消费者的 application.yml 文件中加上这个配置 ......
RabbitMQ 接收队列的消息
代码示例： 注：要把这个类加上Component注解 package com.itheima.amqp_listener;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframewo ......
RabbitMQ 发送消息到队列（交换机不参与的那种）
1. 导包 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId></dependency> 2.在 application.yml 文件里编 ......
关于Vue3中调试APP触发异常：exception:white screen cause create instanceContext failed,check js stack -> at useStore (app-service.js:2309:15)解决方案
bug：reportJSException >>>> exception function:createInstanceContext, exception:white screen cause create instanceContext failed,check js stack ->at us ......