<div class="iteye-blog-content-contain" style="font-size: 14px">
在有了构建RabbitMQ 静态Shovel的经验,构建动态Shevol有显得容易多了
首先和构建静态Shovel一样,先运行两个RabbitMQ节点rabbitmq_a和rabbitmq_b,然后给rabbitmq_a设置shevol:
docker exec rabbitmq_a bash -c "rabbitmqctl set_parameter shovel my-shovel '{\"src-uri\": \"amqp://guest:guest@172.17.0.2:5672/%2f\", \"src-queue\": \"my-queue\", \"dest-uri\": \"amqp://guest:guest@172.17.0.3:5672/%2f\", \"dest-queue\": \"another-queue\", \"ack-mode\": \"on-confirm\"}'"
注意需要用转义符"\"
Consumer类
public static void main( String[] args ) throws IOException { init(); boolean autoAck = false; channel.basicConsume("another-queue", autoAck, "myConsumerTag", new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String routingKey = envelope.getRoutingKey(); String contentType = properties.getContentType(); LOGGER.info("routingKey is:" + routingKey); LOGGER.info("contentType is:" + contentType); long deliveryTag = envelope.getDeliveryTag(); // (process the message components here ...) LOGGER.info("content is:" + new String(body,"UTF-8")); channel.basicAck(deliveryTag, false); } }); } public static void init() { factory = new ConnectionFactory(); factory.setUsername("guest"); factory.setPassword("guest"); factory.setVirtualHost("/"); factory.setHost("172.17.0.3"); factory.setPort(5672); try { connection = factory.newConnection(); channel = connection.createChannel(); } catch (IOException e) { e.printStackTrace(); } catch (TimeoutException e) { e.printStackTrace(); } }
Producer
@Test public void direct() throws IOException { AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().contentType("text/plain").build(); byte[] messageBodyBytes; for (int i = 0; i < 3; i++) { messageBodyBytes = ("Dynamic Shovel Test! No." + i).getBytes(); channel.basicPublish("", "my-queue", properties, messageBodyBytes); } }
</div>
相关推荐
NULL 博文链接:https://gwj41.iteye.com/blog/2376351
docker安装rabbitmq3.8集群-3台-详细笔记文档-带安装包
docker-rabbitmq-cluster集群搭建docker-rabbitmq-cluster集群搭建
1.Docker搭建RabbitMQ集群
2020谷粒商城课件手敲版,视频官网已经放出来了,但是里面讲课的课件没有,找了好久也没找到,于是乎就有了手敲版的docker部署rabbitmq,仅是docker部署rabbitmq部分。
ARM版本的 rabbitmq 镜像资源 版本 3.8.9 使用拷贝到主机 执行:docker load < rabbitmq_arm3.8.9.tar 生成docker镜像
docker,rabbitmq,安装配置与启动,默认用户与密码
docker安装rabbitmq并整合springboot
本篇文章主要介绍了docker搭建rabbitmq集群环境的方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
RabbitMQ服务器使用Erlang编程语言编写,并基于Open Telecom Platform框架构建,用于集群和故障转移。 与代理接口的客户端库适用于所有主要编程语言。 TL; DR $ docker run --name rabbitmq bitnami/rabbitmq:...
完成在docker中安装rabbitmq,简单易上手,命令行解释,每个命令的含义等详解。 解决了docker内部安装完成,外部浏览器无法访问的问题。
docker安装RabbitMQ及安装延迟插件.doc
Windows操作系统下,基于Docker,创建rabbitmq容器,建立消息队列服务
Docker 部署RabbitMQ
docker安装rabbitmq3.8-单点-详细笔记文档-带安装包
docker-compose构建RabbitMQ集群镜像包
docker 安装 rabbitmq
docker-rabbitmq-mqtt 启用了 mqtt 的 rabbtimq 的 Docker 镜像
各种工具(Elasticsearch、Docker、rabbitmq)的学习与集成以及python封装实现
window环境下,docker安装与相应rabbitMQ安装指令。以及相关的实现demo。实现参考 https://www.cnblogs.com/xifengxiaoma/p/11121355.html