轨迹rocketmq消息
RocketMQ 系列(五）高可用与负载均衡
RocketMQ 系列(五）高可用与负载均衡 RocketMQ 前面系列文章如下： RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 系列(四) 消息存储 上一篇讲了 RocketMQ 的消息存储 ......
go-zero 消息队列使用
消息队列对于大型微服务系统是必不可少的，主要是用来解决削峰、降低服务之间的耦合度以及异步能力。 go-queue 在 segmentio/kafka-go 这个包基础上，使用 go-zero 进行了上层统一封装，让开发人员更容易上手，将更多时间聚焦在开发业务上。https://github.com/ ......
消息理论引入
历史 自诞生以来，信息论的主要作用就是通过确定各种通信系统性能的基本限制，为工程界和科学界提供通信理论的数学框架。克劳德-埃尔伍德-香农（Claude Elwood Shannon，1916-2001 年）发表了开创性的著作，断言只要传输速率低于某个取决于信道统计特性的固定量，就有可能以固定的正速率 ......
filebeat收集nginx日志发送到kafka，Logstash 读取 Kafka 日志消息队列到Elasticsearch，kibana做图形展示
服务器配置 es集群：10.0.0.70、10.0.0.71、10.0.0.72kibana：10.0.0.73mysql：10.0.0.73filebeat1-web1：10.0.0.74filebeat2-web2：10.0.0.76kafka1-logstash1：10.0.0.77kafka ......
微信使用python定时主动群发消息
目前市面上的微信营销软件，绝大部分是模拟登录或者进程hook外挂形式，属于违规使用微信的范畴，容易被微信官方封号。经过思考后，我觉得利用python自动化UI点击，鼠标键盘操作，是符合真人使用微信的习惯的，被封的风险最低。因为必须是UI自动化，所以我们使用windows系统，并且结合微信电脑版来实现 ......
3.4 DLL注入：全局消息钩子注入
SetWindowHookEx 是`Windows`系统的一个函数，可用于让一个应用程序安装全局钩子，但读者需要格外注意该方法安装的钩子会由操作系统注入到所有可执行进程内，虽然该注入方式可以用于绕过游戏保护实现注入，但由于其属于全局注入所以所有的进程都会受到影响，而如果想要解决这个问题，则需要在`D... ......
Kafka 生产和消费消息（命令行下）
注：生产消息之前要先建立topic,如下图所示 以下是kafka-topics.bat命令的几个参数介绍 1.生产消息 2.消费消息 ......
Learn Git in 30 days——第 16 天：善用版本日志 git reflog 追踪变更轨迹
写的非常好的一个Git系列文章，强烈推荐 原文链接：https://github.com/doggy8088/Learn-Git-in-30-days/tree/master/zh-cn 其实学习 Git 版本控制的指令操作并不难，但要弄清楚 Git 到底对我的仓库做了什么事，还真不太容易。当你一步 ......
阿里三面：MQ 消息丢失、重复、积压问题，如何解决？
作者：美得让人心动 来源：https://blog.csdn.net/gu131007416553/article/details/120934738 面试官在面试候选人时，如果发现候选人的简历中写了在项目中使用了 MQ 技术（如 Kafka、RabbitMQ、RocketMQ），基本都会抛出一个问 ......
RabbitMQ、RocketMQ和Kafka的不同之处
RabbitMQ、RocketMQ和Kafka是三种常见的消息队列系统，它们在设计和使用方面有一些不同之处： 架构设计： RabbitMQ：RabbitMQ是一个基于AMQP（高级消息队列协议）的开源消息队列系统，采用的是传统的Broker架构模式，其中包括生产者、消费者和中间件（Broker）。 ......
C# 将异步消息分派到同步上下文中
封装一个异步方法类： using System; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Collections.Specialized; using System.Co ......
一次kafka消息丢失问题处理
背景&现象 生产微服务架构环境，kafka消息消费服务架构如下： 当服务B接口出现宕机或者B接口调用超时，kafka消息消费端服务A出现异常，异常发生后未执行手动提交offset操作。待服务B恢复后，消费端A服务也恢复正常，但之前消费异常的消息在broker自动变为已消费，实际未消费（数据库中无处理 ......
消息队列 RabbitMQ
发布者：生产者，消息的发送方。连接：网络连接。Channel：信道，多路复用连接中的一条独立的双向数据流通道。Exchange：交换器（路由器），负责消息的路由到相应队列。类型：direct、fanout、topicBinding：队列与交换器间的关联绑定。消费者将关注的队列绑定到指定交换器上，以便 ......
消息队列与共享内存
消息队列与共享内存 1. 消息队列 1.1 消息队列的概述 消息队列是消息的链表，存放在内存中，由内核维护 消息队列的特点 1.消息队列中的消息是有类型的 2.消息队列中的消息是有格式的 3.消息队列可以实现消息的随机查询。消息不一定要以先进先出的次序读取，编程时可以按消息的类型读取 4.消息队列允 ......
将积压的kafka消息批量消费完(不做处理)
要重置 Kafka 消费者的当前 offset，你可以使用 Kafka 提供的 kafka-consumer-groups.sh 命令行工具来执行重置操作。以下是如何执行重置 offset 的步骤： 确定要重置 offset 的消费者组的名称和消费主题的名称。 使用 kafka-consumer-g ......
RocketMQ 系列(四) 消息存储
RocketMQ 系列(四) 消息存储 本文是 RocketMQ 系列的第四篇，下面是前面几篇的文章，不清楚的话点击看一下吧。 RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 作为一款优秀的分布 ......
关于Android开发中推送消息通知推送消息到前台的问题
为什么推送点击发送按钮之后没有消息进行发送？（以简单音乐播放器为例） 1. 前景 创建了一个Activity : ForegroundServiceActivity.java // 代码如下： package com.app.custom.demo01; import androidx.appcom ......
RocketMQ源码(五)：RocketMQ消息存储流程
在RocketMQ源码(四)：RocketMQ生产者发送消息流程中已经对生产者同步发送消息的源码做了分析，下面继续分析，消息发送到Broker做了哪些处理。 一、Broker处理请求消息的入口 在RocketMQ源码(三)：RocketMQ服务端启动流程中提到，在启动BrokerControler流 ......
【RocketMQ】消息的拉取总结
在上一讲中，介绍了消息的存储，生产者向Broker发送消息之后，数据会写入到CommitLog中，这一讲，就来看一下消费者是如何从Broker拉取消息的。 RocketMQ消息的消费以组为单位，有两种消费模式： 广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。 ......
Jmeter获取Websocket多帧消息的实现方法
由于需要对WebSocket进行压力测试，因此又回归到了JMeter的使用。网络上缺少具体的获取多帧消息的操作，且自己也踩了两个坑，总结一下可行的操作供大家参考。 一、情况说明 被测试的WebSocket会根据客户端发起的信息进行回复，回复帧数不确定。现在需要把所有回复的内容都获取到 二、工具 经过 ......
【1.0】消息队列引入
【一】什么是消息队列 消息队列是一种基于"先进先出"（FIFO）原则的数据结构，用于在分布式系统中进行异步通信和解耦功能模块。 它提供了一种可靠的方式来传递和存储消息，确保消息在发送和接收之间的可靠性和顺序性。 【二】消息队列解决什么问题 【1】应用解耦 通过消息队列，可以将单体应用拆分成多个小功能 ......
【4.0】RabbitMQ使用之消息安全
【一】消息安全之ack ACK是一种确认机制，用于确保消息在消费者接收后被正确处理。 当消费者接收到消息并成功处理时，它发送一个ACK（Acknowledgement）给生产者，表示消息已经处理完毕。 只有在收到ACK之后，生产者才会从队列中删除该消息。 我们使用RabbitMQ作为消息中间件，并通 ......