消息队列工具 - 程序员宅基地

消息队列异步请求，客户端同步收到结果

如何设计一个接口，使用消息队列异步请求，但是客户端同步收到结果异步处理，同步返回？为什么会有这样一个需求？既然接口要求同步返回，那么直接阻塞就好了，要什么异步消息同步返回？高并发保护系统的手段是...

aws-move-queue-messages:该项目提供了一个CLI工具，用于将消息从一个AWS SQS队列移至另一个

标签： aws queue sqs deadletter-queue dev-tool JavaScript

该项目提供了一个CLI工具，用于将消息从一个AWS SQS队列移至另一个。例如，再次运行来自死信队列的失败消息。要求 AWS环境配置纱线或npm 节点安装使用纱： $ yarn global add @joblocal/aws-move-queue-...

FreeRTOS — 消息队列

1、消息队列 1.1 消息队列的概念及其作用　消息队列就是通过 RTOS 内核提供的服务，任务或中断服务子程序可以将一个消息（注意，FreeRTOS消息队列传递的是实际数据，并不是数据地址，RTX，uCOS-II 和 u...

Redisson 延迟队列消息“丢失”问题解决

标签： redisson 延迟队列消息丢失

记录下，最近在项目中使用Redisson 延迟队列遇到的消息“丢失”问题及解决方案

Redis_19_Redis实现消息队列

标签： redis 数据库 java

文章目录一、前言二、Redis三、Redis实现消息队列3.1 环境准备3.2 相关依赖3.3 application.properties配置文件3.4 代码编写3.5 redis队列监听器（消费者）3.6 redis队列推送服务（生产者）3.7 遇到的问题及解决办法...

【消息中间件MQ系列】消息队列之ActiveMQ、RocketMQ、RabbitMQ、Kafka不得不说的秘密

标签：消息中间件对比消息队列对比常用的消息中间件

1.消息队列/消息中间件介绍 1.1消息中间件是什么 1.1.1消息中间件的组成 1.2消息中间件能干什么 1.3消息中间件怎么用 1.3.1消息传递模式 1.3.2 消息中间件种类 1.3.3 各类消息中间件的具体使用操作 2...

阿里云RocketMQ—手把手带你体验云消息队列RocketMQ

标签：阿里云 rocketmq 分布式

今天我对阿里的又一产品进行了深度测评（RocketMQ），首先如果是新用户的话，可以先关注下面这个免费体验的活动。

消息队列之-Kafka原理讲解

标签： kafka zookeeper 消息队列

发布和订阅记录流，类似于消息队列或企业消息传递系统以容错的持久方式存储记录流记录发生时的处理流 Kafka 通常用于两大类应用：构建可在系统或应用程序之间可靠获取数据的实时流数据管道构建转换...

34｜WebSocket：如何在消息队列内核中支持WebSocket？

消息队列需要支持WebSocket协议，以实现高度实时性和低延迟的双工通信特性。内核中支持WebSocket协议需要确定支持的功能、设计生产、消费等功能的请求和返回协议，并支持WebSocket Server。 WebSocket协议的设计与...

MQ消息队列-面试题

消息队列是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。什么是JMS？ Java消息服务（Java Message Service）即JMS，是一个Java平台中关于面向消息中间件的...

RabbitMQ高级（消息可靠性、死信交换机、惰性队列、MQ集群部署）

标签： rabbitmq rabbitmq 网络工具

RabbitMQ高级（消息可靠性、死信交换机、惰性队列、MQ集群部署）及详细部署

NSQ消息队列调研与使用

标签： nsq 消息队列分布式

消息队列解决的问题模块间解耦：将一个流程加入一层数据接口拆分成两个部分，上游专注通知，下游专注处理，服务接口依赖变为数据依赖消息的异步：上游发送消息以后可以马上返回，处理工作交给下游进行，最终一致...

Springboot 使用配置文件动态创建RabbitMq消息队列

标签： rabbitmq spring

在Spring启动时，利用Spring Bean管理工厂BeanFactory接口，实现动态创建交换机、队列、交换机和队列的绑定关系，让我们无需进行重复的编码工作。源码解析 spring动态注入bean /** * 将bean对象注册到bean工厂 ...

MQTT消息队列遥测传输协议，EMQX消息服务器搭建以及使用Springboot项目连接EMQX服务器实现消息推送和接收

标签： springboot 网络协议

MQTT消息队列遥测传输协议，EMQX消息服务器搭建以及使用Springboot项目连接EMQX服务器实现消息推送和接收

RabbitMQ 消息队列学习笔记

服务环境：Centos 7 客户端环境：windows、 IDEA、Java 1.1.0、安装Erlang： wget http://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm rpm -Uvh erlang-solutions-1.0-1.noarch.rpm ...

分布式消息队列浅析

队列作为一种比较抽象的数据结构，在程序世界中被广泛的应用，而实现方式和形态也各式各样，有使用进程内堆栈实现的，如stl库中的queue;有基于管道、Shmem实现的，如常见的同机进程间通信模型，而随着分布式系统应用...

cherami-server, 分布式可以扩展持久和高度可用的消息队列系统.zip

标签：开源

cherami-server, 分布式可以扩展持久和高度可用的消息队列系统 cherami服务器是一个分布式。可以伸缩。持久和高可用性的消息队列系统，我们在Uber工程中开发了一个。这个 repo 包含Cherami服务器的源代码。交叉区...

面试题：管道、消息队列、共享内存哪个开销最小？

标签： linux Unix

Linux包含多种进程间通信（interprocess communication，或者IPC），我们或多或少在面试中都被问及IPC的相关知识，所以这篇文章记录总结一下自己对于IPC的认识和理解吧！概述进程间的通信手段大体可以分为两类： ...

Spring Boot进阶(05)：Spring Boot与RabbitMQ完美融合，打造高效消息队列服务！

标签： rabbitmq spring boot rabbitmq使用

Springboot如何整合RabbitMq，若不会，我便手把手教你，超级详细

基于消息队列（RabbitMQ）实现延迟任务

标签： java 程序人生学习

生产者将带有延迟信息的消息发送到RabbitMQ交换机中，等待延迟时间结束方将消息转发到绑定的队列中，消费者通过监听队列消费消息。延迟任务的关键在消息在交换机中停留。显而易见，基于RabbitMQ实现延迟任务对...

Java服务MQ消息队列容灾方案

标签： MQ MQ容灾消息队列容灾

在前一段时间线上出现过一次事故，一个非常重要的消息生产者服务，由于MQ出现问题，消息大量积压，导致了该服务线程被打满，外部请求返回502，服务采用Springboot搭建，使用Springboot的Tomcat容器。原因分析 ...

消息队列专题(进阶篇)：RabbitMQ 介绍与环境搭建

标签：消息队列 rabbitmq

之前写过一篇博客简单介绍了消息队列的基础知识，当时立下了 Flag，说好下次会专门介绍 RabbitMQ，说到做到，前来填坑。消息队列入门基础篇博客链接如下： ... 什么是 RabbitMQ RabbitMQ 是实现了高级消息队列协议...

查看kafka消息队列的积压情况

标签： kafka 分布式

创建topic kafka-topics --create --zookeeper master:2181/kafka2 --replication-factor 2 --partitions 3 --topic mydemo5 列出topic kafka-topics --list --zookeeper master:2181/kafka2 ...