activemq gt rabbitmq rocketmq
RabbitMQ自学笔记
#RabbitMQ笔记总结 ## 常见概念 **Broker**：消息服务器，类似于Mysql服务器。 **Channel**：连接中的一个虚拟通道，消息队列发送或者接收消息时，都是通过信道进行的。 **Virtual host**：类似于Mysql数据中的数据库，库与库之间的是独立的， ......
canal+RabbitMQ实现Redis与Mysql解决双写一致性
# canal+RabbitMQ实现Redis与Mysql的数据最终一致性问题 ## 配置mysql(windows版本)  2.安装 ......
Linux终端中>和>>的区别
例如，Linux 中最常用的运算符集之一是方向运算符。方向运算符将命令的输入或输出重定向到文件或任何其他命令。 重定向有两种方法：输入重定向和输出重定向。对于输入重定向，我们使用小于<符号，对于输出重定向大于>符号，也称为尖括号。 区别 >：覆盖现有文件，如果目录中不存在上述名称的文件，则创建一个文 ......
万字长文讲透 RocketMQ 4.X 消费逻辑
RocketMQ 是笔者非常喜欢的消息队列，4.9.X 版本是目前使用最广泛的版本，但它的消费逻辑相对较重，很多同学学习起来没有头绪。 这篇文章，笔者梳理了 RocketMQ 的消费逻辑，希望对大家有所启发。  -> int: # 返回值注解 表明了函数的返回值为int类型 return x + y ......
2023-06-05 hexo 分页图标不显示，显示的是【<i class="iconfont icon-arrow-left"></i>】
问题描述：如题。 注意：我使用的主题为next。 解决方案：全局搜索：nav class="pagination"或者找到路径：你的博客\themes\hexo-theme-next\layout\_partials里的【pagination.swig】文件，对其进行修改； 修改前： {% if p ......
docker-compose快速安装redis、redis集群、activemq、elasticsearch(head、ik、kibana、logstash)、mongodb、zookeeper等环境
基本操作 部署docker容器并启动(进入docker-compose.yml文件所在目录执行) docker-compose up -d 关闭容器(同理) # 停止服务 docker-compose stop #停止并删除容器、网络、卷、镜像。 docker-compose down 查看当前do ......
RabbitMQ
# 一、消息队列介绍 MQ的全称是Message Queue——消息队列。 MQ是一种应用程序对应用程序的通信方法。 MQ是消费者-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息。 这样发布者和使用者都不用知道对方的存在。 > 生产者-消费者模式是通过一个容 ......
类型转换static_cast<type>(value)
来自CHATGPT的回答 static_cast<float>(value) 和 (float)value 实际上是完成相同的类型转换，即将 value 的类型转换为 float 类型。两者的区别在于语法和一些特定的使用情境。 语法：static_cast<float>(value) 是使用 C++ ......
读<Wireshark数据包分析实战-第3版>之ICMP,STP,DHCP
#ICMP协议 ICMP（Internet Control Message Protocol，互联网控制报文协议）是一个网络层协议，用于在IP 主机和路由器之间传递控制消息。它主要负责提供关于网络通信问题的反馈，如无法到达的目标主机、不可达的网络等。ICMP 位于 TCP/IP 协议栈中的第三层，即 ......
读<Wireshark数据包分析实战-第3版>之255.255.255.255
255.255.255.255 是一个特殊的 IPv4 地址，被称为受限广播地址（Limited Broadcast Address）。当一个设备发送一个数据包到 255.255.255.255，网络中所有连接在同一局域网（LAN）的设备都会收到并处理该数据包。 受限广播地址主要用于以下场景： 1. ......
消息队列RocketMQ基本概念
1 消息模型（Message Model） RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储 ......
rabbitmq消息队列
# 消息队列Rabbitmq ## 1. 什么是消息队列(MQ) Message Queue消息队列是一种应用程序对应用程序的通信方法, 可以是线程(Queue), 也可以是`进程之间`, 而`rabbitmq`是进程之间的消息队列 `生产者消费者模型`: 通过一个容器来解决生产者和消费者之间的强耦 ......
Rabbitmq在linux服务器的安装步骤
Linux系统：CentOS7.x （如果是CentOS8.x的话，需要修改下面两个环境版本号中的el7为el8） Erlang：erlang-22.3.4.12-1.el7.x86_64.rpm RabbitMQ：rabbitmq-server-3.8.13-1.el7.noarch.rpm 1 ......
什么是 Apache ActiveMQ？
# 什么是 ActiveMQ？ ActiveMQ 是一种流行的消息传递服务，可促进企业系统中大规模的不同数据。在本 ActiveMQ 教程中，我们概述了 ActiveMQ、它的优点、它的工作原理以及何时应该使用它。 什么是 ActiveMQ？ ActiveMQ 是一种流行的开源消息传递服务，它构建在 ......
springboot项目rabbitmq消费者消费json格式的String，出现无限循环抛出No method found for class [B
转： springboot项目rabbitmq消费者消费json格式的String，出现无限循环抛出No method found for class [B ......
<未完成>python使用oletools提取docx文件中的嵌入文件（指word中的插入对象）
上午在帮一个同事实现题目中的功能，主要参考的是这篇博客https://zhuanlan.zhihu.com/p/530612244 但是在复现的过程中失败了，下面详细说说。 首先我的环境是centos，参考的博客是在windows中实现的。 博客的实现的步骤主要有两个，一个是将docx文件中的嵌入文 ......
RocketMQ启动和端口介绍【转】
关闭namesrv和broker 关闭namesrv服务 #进入bin sh mqshutdown namesrv 如图 关闭broker服务 sh mqshutdown broker 如图 通过jps验证下 如图 第五节：防火墙配置宿主机需要远程访问虚拟机的rocketmq服务和web服务，需要开 ......
.Linux nohup、&、 2>&1解释
.Linux nohup、&、 2>&1解释通常起一个jar 文件的时候可以直接通过java -jar 来启动，比如：A.nohup java -jar -Dspring.profiles.active=xxx -Dserver.port=xxx xxx.jar >security.out 2>&1 ......
1.RabbitMQ简介与入门
# 1.简介与入门 ## 1.1.MQ介绍 ### 1.1.1.概念 MQ(message queue)，本质是个队列，FIFO 先入先出，只不过队列中存放的内容是 message 而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ 是一种非常常见的上下游“逻辑解耦+物理解耦” ......
Provider parse errors: Cannot instantiate cyclic dependency! ApplicationRef ("[ERROR ->]")
异常： 异常的原因： 自定义的一个全局异常类，在它的构造器中注入Router路由就抛出这个循环依赖的异常 解决方式： 使用injector ......
windows10环境下安装RabbitMQ以及延时插件（图文）
> 安装转载：https://www.cnblogs.com/saryli/p/9729591.html > > 插件转载：https://blog.csdn.net/nbdclw/article/details/107441772 #### 安装及配置环境 ##### 第一步：下载并安装erlan ......
RabbitMq镜像策略模式
镜像策略 ha-mode ha- params 说明 exactly count 集群中队列副本的数量（主队列加上镜像）。count值为1表示一个副本：只有主节点。如果主节点不可用，则其行为取决于队列是否持久化。count值为2表示两个副本：一个队列主队列和一个队列镜像。换句话说:“镜像数=节点数- ......
Lambda表达式 o=>o.ID
1. dbMSpeakers = this.GetObjects(new MeetingSpeaker { MeetingSn = meeting.Sn }, " and Type in ('-1','0','1','2','3','5')"); if (dbMSpeakers.All(o => o ......
rocketmq生产环境升级（干货）
方案一： 升级 K8s pod资源 交替清空其中一组 broker(m-s) 消息，重启pod 优点：操作简单，无需新增资源，在原有资源上扩容 缺点：只完成当前升级，最大只能升级到4C 8G，后续业务量起来有可能还需要升级（升级硬件） 操作： 1. 摘除写入流量 brokerPermission=2 ......
vue报<% if (process.env.NODE_ENV === 'production') { %> <% }else { %> <% } %>
由于系统重装，运行项目，后台报node-sass@4.13.1 postinstall: `node scripts/build.js` 页面报 大概率node-sass有问题 ``` 1、卸载： npm uninstall node-sass 2、安装： npm install node-sass ......
RabbitMQ - 使用amqp库连接RabbitMQ（实例使用）
1、发送端 步骤分解如下：（1）建立连接conn, err := amqp.Dial("amqp://admin:admin@dev.com:5672/") （2）打开channel这里的channel 是AMQP 里的概念，可以理解为 多路复用的一个tcp长连接。 （3）声明一个队列q, err ......