轨迹rocketmq消息
【Apollo】【三】发布配置的过程-变更配置消息的发送与消费
1 前言 上节我们看了下发布配置的 Portal 以及 Admin Service的变化过程，我们看到Admin Service 的 messageSender.sendMessage()，发送消息以及消费消息，那么这节我们继续看。 2 MessageSender 发送消息 2.1 ReleaseM ......
RocketMQ 系列(二) 环境搭建
## RocketMQ 系列(二) 环境搭建 上一个章节对于 RocketMQ 作了一些概念上的介绍，如果你对于 RocketMQ 没有概念，不妨先看[RocketMQ系列(一) 基本介绍](https://www.cnblogs.com/CF1314/p/17662969.html)。 这个章节主 ......
在.NET Framework中使用RocketMQ（阿里云版）实战【第二章】
上一章节主要介绍了RocketMQ基本介绍和前期准备，以及如何创建生产者。那这一章节主要介绍一下消费端的实现、如何发布消费端，以及遇到的坑怎么去解决。 ......
消息推送 架构设计
文章很长，且持续更新，建议收藏起来，慢慢读！[**疯狂创客圈总目录 博客园版**](https://www.cnblogs.com/crazymakercircle/p/9904544.html) 为您奉上珍贵的学习资源 ： 免费赠送 :[**《尼恩Java面试宝典》**](https://www. ......
园子的脱困努力-线上大会合作：欢迎预约直播——2023腾讯全球数字生态大会 + 腾讯云微服务与消息队列专场
腾讯2023全球数字生态大会将于 「2023.9.7(周四) ~ 2023.9.8(周五)」在线上举行，大会主题是“智变加速，产业焕新”。在园子的困难时期，腾讯云给园子带来了惊喜，选择了和园子进行这次线上大会的推广合作，希望通过合作让更多开发者观看大会直播。本来腾讯云想合作3个推广，1个大会，2个专... ......
成品直播源码平台消息传递的协议：MMS协议
通过MMS协议，使成品直播源码平台实现了多种媒体形式的实时传输、广播与通知、多种互动功能与流控制，让成品直播源码平台成为了一个高质量的平台，保证用户在使用成品直播源码平台的时候能体验到平台的稳定与流畅性，为用户提供更好的体验。 ......
Apache RocketMQ 5.0 消息进阶：如何支撑复杂的业务消息场景？
首先来看 RocketMQ 的第一个特性-事务消息，事务消息是 RocketMQ 与一致性相关的特性，也是 RocketMQ 有别于其他消息队列的最具区分度的特性。 ......
Kafka - 不仅是消息引擎，还是分布式流处理平台
如果你通读全篇文字但只能记住一句话，我希望你记住的就是这句 Apache Kafka 是消息引擎系统，也是一个分布式流处理平台（Distributed Streaming Platform） 作为流处理平台，Kafka 与其他主流大数据流式计算框架相比，优势在哪里呢？我能想到的有两点。 第一点是更容 ......
redis 消息队列方案
1. List 实现消息队列 - 使用LPUSH、RPOP 左进右出或RPUSH、LPOP 右进左出，实现消息顺序消费 - 使用 BLPOP、BRPOP 这种阻塞式读取的命令，实现消息及时消费 - ack 机制 使用，使用index 读取list 的消息，正常消费完成后再使用POP删除 ```jav ......
RocketMQ系列(一) 基本介绍
## RocketMQ系列(一) 基本介绍 ### 1、MQ 作用 MQ 的应用场景主要包含以下 3 个方面： #### 1.1、异步与解耦 当我们下了一个订单之后，订单服务会进行 RPC 同步调用 支付服务、库存服务、物流服务等，那么服务之间就会有耦合性，耦合性越高的话，容错性就越低，比如我们的支 ......
在.NET Framework中使用RocketMQ（阿里云版）实战【第一章】
在开发某一个需求的时候，领导要求使用RocketMQ(阿里云版) 作为消息队列。生产者主要有WebAPI/MVC/JOB(控制台应用程序)，然后消费者采用的是Windows服务。那[西瓜程序猿]来记录一下如何使用RocketMQ(阿里云版)，给各位小伙伴作为参考防止踩坑。 ......
关注微信公众号推送消息
微信关注二维码的主要开发思路： 第一步，向用户展示要扫的二维码：通过提前申请的appid和秘钥去拿token，通过token再去微信服务上拿要关注的图片二维码，将二维码展示在你系统中。 第二步，用户扫码: 用户扫码时会向微信发信息，并且微信会回调你的自己的服务，需要你将关注的用户信息保存下来; 第三 ......
System.Messaging.MessageQueueException: 对消息队列系统的访问被拒绝
无法启动服务。System.Messaging.MessageQueueException: 对消息队列系统的访问被拒绝。使用Windows的消息队列时，窗体界面的应用可以对消息队列进行全部权限的操作，但是编写的Windows服务对消息队列进行操作时有可能会出现此错误提示，在这里提供一种解决方法： ......
安装 rocketmq dashboard
安装 rocketmq dashboard 可以帮助查看rocketmq中消息消费情况。 https://github.com/apache/rocketmq-dashboard 下载代码后，进入下载目录 打包： mvn clean package -Dmaven.test.skip=true 运行 ......
PRACK消息
概述 PRACK消息是sip协议的扩展，在RFC3262中定义，标准的名称是sip协议中的可靠临时响应。 本文简单介绍标准中对PRACK消息流程的描述，以及fs配置PRACK的方式。 环境 centos：CentOS release 7.0 (Final)或以上版本 freeswitch：v1.10 ......
windows 桌面GUI自动化- 15.pywinauto电脑端微信自动发聊天消息实现
# 前言 前面学了pywinauto 基础操作手，总不能老拿记事本练手，是时候找个常用的应用实战了，比如用微信实现自动发消息。 # 连上微信 先自己登录微信，打开窗口， 用`connect` 连上微信窗口 : SUCCESS = "S" WARNING = "W" ERROR = "E" ABORT = "A" INFORMATION = "I" class SapStatusMessage: def __init__(self ......
Redis消息队列实现异步秒杀
## Redis消息队列 消息队列(Message Queue)，字面意思就是存放消息的队列。最简单的消息队列模型包括3个角色: - 消息队列：存储和管理消息，也被称为消息代理 - 生产者：发送消息到消息队列 - 消费者：从消息队列获取消息并处理消息 ![image](https://img2023 ......
Apache Dubbo 和 Apache RocketMQ 邀您参与，ASF 亚洲峰会 5 张门票免费送
今年，CommunityOverCode Asia 2023 将是阿帕奇亚洲大会的首次线下会议，北京，8 月 18 日至 20 日。会议将持续 3 天，设有 17 个论坛方向，共收集到 150 余个议题投稿，其中中文议题约 110 个，英文议题近 40 个。 ......
Argo CD 消息通知
## Argo CD 消息通知 有的时候我们可能希望将应用同步的状态发送到指定的渠道，这样方便我们了解部署流水线的结果，最新版本 `Argo CD` 也内置了 `ArgoCD Notifications` 用于同步状态通知功能，同时我们也可以与第三方的系统进行集成。 * [ArgoCD Notifi ......
消息队列 & RabbitMQ
消息队列 & RabbitMQ 使用总结 1.消息队列 定义：message queue 是消息传递过程中一种存储数据的结构。 2.特点：先进先出，可以设置优先级用于大客户优先发货，持久化，消息确认，延时队列用于订单30分钟未支付取消。 3.作用：应用解耦，肖峰填谷，异步提高响应速度 4.Rabbi ......
kafka发送超大消息
kafka发送超大消息设置 最近开发一cdc框架，为了测试极端情况，需要kafka传递100万条数据过去，1个G左右，由于其他环节限制，不便进行拆包（注：测下来，大包走kafka不一定性能更好，甚至可能更低）。 测试百万以上的变更数据时，报消息超过kafka broker允许的最大值，因此需要修改如 ......
k8s部署rocketmq
分别部署rocketmqnamesrv、rocketmqbroker、rocketmq-dashboard三个。 1、部署rocketmqnamesrv 部署时，rocketmq的日志存储采用hostPath方式挂载到服务器磁盘上，所以需要指定node节点。 apiVersion: apps/v1 ......
服务端向客户端发送消息Server-Sent Events
今天听说了服务端向客户端发消息的一种方式：Server-Sent Events SSE使用的是HTTP协议，本质上是服务端向客户端发送流式数据。 HTTP不支持服务端向客户端发送请求，但是如果客户端向服务端发出请求后，服务端向客户端声明，接下来的数据是流信息，则连接不会关闭，服务端可以继续发送数据流 ......
springboot~kafka中延时消息的实现
# 应用场景 * 用户下单5分钟后,给他发短信 * 用户下单30分钟后，如果用户不付款就自动取消订单 # kafka无死信队列 kafka本身没有这种延时队列的机制，像rabbitmq有自己的死信队列，当一些消息在一定时间不消费时会发到死信队列，由死信队列来处理它们，上面的两个需求如果是rabbit ......