docker安装rabbitmq延时插件rabbitmq_delayed_message_exchange

小鱼儿 2022-12-25 03:54 588阅读 0赞

*  **第一种方式是进入容器内部去安装**

首先下载镜像和启动

rabbitmq:
        restart: always
        image: rabbitmq:management
        container_name: rabbitmq
        ports:
          - 5672:5672
          - 15672:15672
        networks:
          default:
            ipv4_address: 172.18.0.5
        environment:
          TZ: Asia/Shanghai
        volumes:
          - ./rabbitmq/data:/var/lib/rabbitmq
          - /etc/localtime:/etc/localtime

登录web页面查看mq的版本

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70][]

官方网站下载对应版本的插件

插件下载地址：https://www.rabbitmq.com/community-plugins.html
    找到rabbitmq_delayed_message_exchange下载
    https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/tag/3.8.9

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 1][]

将插件上传到服务器

![20201130145458136.png][]

将插件复制到rabbitmq容器内,进入容器安装插件

拷贝至docker容器内
    docker cp rabbitmq_delayed_message_exchange-3.8.9-0199d11c.ez rabbitmq容器ID:/plugins
    进入docker容器内
    docker exec  -it rabbitmq  bash
    赋予权限
    chmod 777 /plugins/rabbitmq_delayed_message_exchange-3.8.9-0199d11c.ez
    启动延时插件
    rabbitmq-plugins enable rabbitmq_delayed_message_exchange

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hZ2ljXzEwMjQ_size_16_color_FFFFFF_t_70][]

验证是否成功, Exchanges的type多了一个x-delayed-message

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 2][]

这种方式容器删除后需要重新配置一遍,可以使用第二种方式

*  **使用DockerFile的方式进行安装**

自己做一个含有rabbitmq\_delayed\_message\_exchange插件的rabbitmq的镜像,以后都使用这个镜像启动rabbitmq

下载插件上传到服务器,编写Dockerfile

![20201130150704172.png][]

from rabbitmq:management
    COPY ["rabbitmq_delayed_message_exchange-3.8.9-0199d11c.ez" , "/plugins/"]
    RUN chmod 777 /plugins/rabbitmq_delayed_message_exchange-3.8.9-0199d11c.ez
    RUN rabbitmq-plugins enable --offline rabbitmq_delayed_message_exchange

构建镜像

我们取名为rabbitmq:delayed
    docker build -t rabbitmq:delayed .

查看

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 3][]

使用

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 4][]

上点java代码测试

spring:
      rabbitmq:
        host: xxx # rabbitmq的连接地址
        port: 5672 # rabbitmq的连接端口号

package cc.sunni.rabbitmqdelayedmessagedemo.config;
    
    import org.springframework.amqp.core.Binding;
    import org.springframework.amqp.core.BindingBuilder;
    import org.springframework.amqp.core.CustomExchange;
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.util.HashMap;
    import java.util.Map;
    
    @Configuration
    public class DelayedMessageConfig {
        public final static String QUEUE_NAME = "delayed.live.queue";
        public final static String EXCHANGE_NAME = "delayed.live.exchange";
    
        /**
         * 声明队列
         */
        @Bean
        public Queue queue() {
            return new Queue(DelayedMessageConfig.QUEUE_NAME);
        }
    
        /**
         * 声明交换机
         */
        @Bean
        CustomExchange customExchange() {
            Map<String, Object> args = new HashMap<>();
            args.put("x-delayed-type", "direct");
            //参数二为类型：必须是x-delayed-message
            return new CustomExchange(DelayedMessageConfig.EXCHANGE_NAME, "x-delayed-message", true, false, args);
        }
    
        /**
         * 绑定队列到交换器
         */
        @Bean
        Binding binding(Queue queue, CustomExchange exchange) {
            return BindingBuilder.bind(queue).to(exchange).with(DelayedMessageConfig.QUEUE_NAME).noargs();
        }
    }

package cc.sunni.rabbitmqdelayedmessagedemo.component;
    
    import cc.sunni.rabbitmqdelayedmessagedemo.config.DelayedMessageConfig;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.amqp.AmqpException;
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.core.MessagePostProcessor;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    @Component
    public class DelayedMessageSender {
        private final Logger log = LoggerFactory.getLogger(DelayedMessageSender.class);
    
        @Autowired
        private AmqpTemplate rabbitTemplate;
    
        public void send(String msg, Integer delaySeconds) {
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            log.info("发送时间:" + sf.format(new Date()));
    
            rabbitTemplate.convertAndSend(DelayedMessageConfig.EXCHANGE_NAME, DelayedMessageConfig.QUEUE_NAME, msg, new MessagePostProcessor() {
                @Override
                public Message postProcessMessage(Message message) throws AmqpException {
                    // 给消息设置延迟毫秒值
                    message.getMessageProperties().setHeader("x-delay", delaySeconds * 1000);
                    return message;
                }
            });
        }
    }

package cc.sunni.rabbitmqdelayedmessagedemo.controller;
    
    import cc.sunni.rabbitmqdelayedmessagedemo.component.DelayedMessageSender;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class MqController {
        public static final Logger log = LoggerFactory.getLogger(MqController.class);
    
        @Autowired
        private DelayedMessageSender sender;
    
        @PostMapping("/mq/{message}/{delay}")
        public String messageWithMQ(@PathVariable(value = "message") String message,
                                    @PathVariable(value = "delay") Integer delay) {
            log.info("Send: " + message);
            sender.send(message, delay);
            return "success";
        }
    
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 6][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70]: /images/20221120/b8fbdc62ae8845c399d37e01ed77843f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 1]: /images/20221120/9daad03e1de54a08a4ffae4815bc7a20.png
[20201130145458136.png]: /images/20221120/da46193e2ae6482089747ade8fcb076f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hZ2ljXzEwMjQ_size_16_color_FFFFFF_t_70]: /images/20221120/0748eb9029224b2eaee806abafc249cd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 2]: /images/20221120/bfb7597824ca42a288af7c4687f4cf79.png
[20201130150704172.png]: /images/20221120/65cd89a469954ef88a4b0ddde75697bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 3]: /images/20221120/da94b71920ff44f3b6063d747f905185.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 4]: /images/20221120/499812aa61c940afa2b763aab167e6ed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 5]: /images/20221120/cd617315c0b6489ba04eab7d941f527d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 6]: /images/20221120/886de2d136094690a5d547a6e0c3416e.png