MQ助手 - 是一个基于pulsar包自研实现的Spring Boot Stater。通过简单注解配置即可进行MQ消息生产与消费。
主要特性
- 基于成熟pulsar包扩展，没有任何框架变动，只为简化开发使用
- 配置简单灵活，无需复杂的配置文件：开发者可以快速注解类或者方法实现消息的生产与消费
- Apache Pulsar 云原生分布式消息流平台，当下最佳解决方案
使用指引
引入依赖
implementation("cool.doudou:mq-assistant:latest")
Pulsar配置
pulsar:
service-url: pulsar://127.0.0.1:6650
subscription-name: sub-celery
subscription-type: Shared
使用方式
消息订阅
- 生产者与topic进行关联绑定
/**
* 生产者主题绑定
*/
@MqProducer(topics = {"celery"})
@Component
public class MqComponent {
}
- 消费者与topic进行关联绑定，注意：每个消费者须绑定一个subscription-name后才能进行消费
/**
* 消费者主题绑定
*/
@Component
public class MqComponent {
@MqConsumer(topics = {"celery"})
public void receive(String topic, byte[] msg) {
System.out.println("consumer: topic[" + topic + "] => " + new String(msg));
}
}
消息发送
- send()：发送
- sendAsync()：异步发送
/**
* 消息发送
*/
@AllArgsConstructor
@Service
public class MqServiceImpl {
private MqHelper mqHelper;
public void test() {
// 同步
String msgId = mqHelper.send("celery", "hello");
System.out.println("send: " + msgId);
// 异步
mqHelper.sendAsync("celery", "您好Async", System.out::println);
// 同步
String msgId = mqHelper.send("celery", new byte[]{0x01, 0x02, 0x03, 0x04});
System.out.println("send: " + msgId);
// 异步
mqHelper.sendAsync("celery", new byte[]{0x01, 0x02, 0x03, 0x04}, System.out::println);
}
}
-
消息队列配置文档: 使用 MongoDB数据库： 1. 安装 MongoDB. 2. easy_install pymongo 3. easy_install celery 4. easy_install django celery 5. settings.py 配置 增加 app INSTALLED_APPS = ('djcelery','tasks',) # Using the d
-
MqTool(消息队列调试工具)Rab bitMQ、ActiveMQ消息队列调试工具用于调试MSMQ、Ra bbitMQ、ActiveMQ三种消息队列,其中MSMQ支持Active、Binary、XML格式,Ra bbitMQ支持逐条接发、批量接发、RPC回调模式、新建队列、建立持久化队列、连接测试等功能。 使用方法： 使用MqTool工具数据投放流程介绍 1.创建send目录文件：把环保
-
基于MCF开发一个白板交互系统，在使用类MessageQueue创建消息队列的时总是提示出错，原来是MSMQ没有安装，MSMQ(MicroSoft Message Queue，微软消息队列)是在多个不同的应用之间实现相互通信的一种异步传输模式。系统安装时默认是没有将该服务安装的。 手动配置安装步骤如下： 1：打开“控制面板”。 2：单击“程序”，然后在“程序和功能”下单击“打开或关
-
MSMQ(MicroSoft Message Queue，微软消息队列)在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台机器上，也可以分布于相连的网络空间中的任一位置。其工作原理是：消息发送方将消息放进消息队列，接收方则从消息队列中取出消息。 用C#实现发送消息的代码如下： （需要引用并包含命名空间System.Messaging） void Send(str
-
1 测试环境和mq版本 1）Red Hat Enterprise Linux AS release 5(Taroon)、 2）mq6_linux.tar 3）6.0.2-WS-MQ-LinuxIA32-FP0009.tar.gz(升级包) 2 创建用户和组 用户和用户组都必须是mqm useradd mqm passwd mqm groupadd mqm [root@localhost ~]#
-
最近MQ用的较多，故在网上找了下资料，也跟大家分享下： ----------------------------- 创建队列管理器 crtmqm qmgrname 删除队列管理器 dltmqm [-z] qmgrname 启动队列管理器 strmqm qmgrname 停止队列管理器 endmqm –i QmgrName 立即停止 endmqm –p QmgrName 强制停止 显示队列管理器 d
-
发送消息到消息队列 private void button1_Click(object sender, EventArgs e) { string queueName=@"./private$/TestQueue"; if (!MessageQueue.Exists(queueName)) {
-
博客已搬家, 更好阅读体验, 猛戳 http://www.jack-yin.com/coding/translation/activemq-in-action/1879.html 14.3 Tools for ActiveMQ administration 14.3 ActiveMQ的管理工具 A wide range of tools exist for monitoring and a
-
如何在 camel中 配置使用 activemq how to configure and use activemq in camel 一、configure activemq, create a xml file "activemq_connect.xml" ,contents as : <?xml version="1.0"?> <beans xmlns="http://www.sprin
-
1. 测试环境 (1) 操作系统 Win7 旗舰版64位 (2) CPU Intel(R) Core(TM) i5-3470 CPU @ 3.2GHz (3) JDK JDK1.6 (4) ActiveMQ ActiveMQ5.7.0 修改配置文件/conf/activemq.xml <persistenceAdapter> <kahaDB directory="
-
package org.abin.lee.jms; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.DeliveryMode; import javax.jms.Destination; import javax.jms.MessageProducer; import javax.j
-
http://www.aspcool.com/lanmu/browse1.asp?ID=700&bbsuser=asp MSMQ(MicroSoft Message Queue，微软消息队列)是在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台机器上，也可以分布于相连的网络空间中的任一位置。它的实现原理是：消息的发送者把自己想要发送的信息放入一个容器中（
-
我们先简单的了解一下 什么是消息队列(MSMQ)？消息队列是 Windows 2000（NT也有MSMQ，WIN95/98/me/xp不含消息队列服务但是支持客户端的运行）操作系统中通讯的基础，也是用于创建分布式、松散连接 通讯应用程序的工具。这些应用程序可以通过不同种类的网络进行通讯，也可以与脱机的计算机通讯。消息队列分为用户创建队列和系统队列。 用户队列分为： · "公共队列"在整个可传递
-
Celery 是一个简单，灵活且可靠的分布式系统，可以处理大量消息，同时为操作提供维护该系统所需的工具。这是一个任务队列，着重于实时处理，同时还支持任务调度。 Celery 通过消息进行通信，通常使用经纪人在 clients 和 workers 之间进行调解。要启动一个任务，客户端会在队列中放入一条消息，然后经纪人将消息传递给工人。 一个Celery系统可以由多个worker和broker组成，从
-
问题内容： 按照此处找到的说明，我将脚本从github复制到 /etc/init.d/celeryd中 ，然后使其可执行； 我按照说明创建了配置文件 / etc / default / celeryd ： 注意 ：我在CELERYD_OPTS中添加了 --config = celeryconfig 部分。 我创建了一个新的用户 celery 与 然后创建集体 celery 并向其中添加用户： 我将
-
问题内容： 按照此处找到的说明，我将脚本从github复制到 /etc/init.d/celeryd中 ，然后使其可执行； 我按照说明创建了配置文件 / etc / default / celeryd ： 注意 ：我在CELERYD_OPTS中添加了 --config = celeryconfig 部分。 我创建了一个新的用户 芹菜 与 然后创建集体 芹菜 并向其中添加用户： 我将chown ce
-
支付助手 - 是一个基于微信支付API、支付宝支付API封装的Spring Boot Stater。通过简单注解配置即可进行支付交易。 主要特性 简单注解配置，即可实现支付相关操作 省掉碍眼繁琐的签名与验签，简化支付交互过程 透传返回交互结果 使用指引 引入依赖 implementation("cool.doudou:pay-assistant:latest") 配置文件 pay: modes
-
File 助手 - 是一个自研实现的Spring Boot Stater。结合多种文件存储平台实现文件上传、下载、预览。 主要特性 基于成熟包扩展，没有任何框架变动，只为简化开发使用 配置简单灵活，无需复杂的配置文件：开发者配置模式后，统一方法实现上传、下载、预览 使用指引 引入依赖 implementation("cool.doudou:file-assistant:latest") 使用方式
-
众所周知，Celery是Python中非常著名的任务队列框架，其中还包含了一个“定时调度任务”的大杀器，其机制大致就是通过Celery内置的celerybeat来开启一个进程，然后把对应worker中的任务定时丢给rabbitmq或者redis来去跑。其实简单的来说，就是当你开启celery的时候，你希望被调度的任务已经开始跑了。 如果有一天我们希望自己来去控制何时开始跑定时任务并且何时去停止，那