{"id":1785,"date":"2023-03-27T22:17:07","date_gmt":"2023-03-27T14:17:07","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1785"},"modified":"2023-04-23T21:15:58","modified_gmt":"2023-04-23T13:15:58","slug":"using-rabbitmq-to-automatically-expire-unpaid-orders-after-30-minutes","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/27\/using-rabbitmq-to-automatically-expire-unpaid-orders-after-30-minutes\/","title":{"rendered":"\u4f7f\u7528RabbitMQ\u5b9e\u73b0\u672a\u652f\u4ed8\u8ba2\u5355\u572830\u5206\u949f\u540e\u81ea\u52a8\u8fc7\u671f"},"content":{"rendered":"<h2>RabbitMQ\u5ef6\u8fdf\u961f\u5217\u5e94\u7528<\/h2>\n<p><strong>\u5ef6\u8fdf\u961f\u5217<\/strong>\u53ef\u4ee5\u5b9e\u73b0\u6d88\u606f\u5728\u6295\u9012\u5230Exchange\u4e4b\u540e\uff0c\u7ecf\u8fc7\u4e00\u5b9a\u7684\u65f6\u95f4\u4e4b\u540e\u518d\u8def\u7531\u5230\u76f8\u5e94\u7684Queue\u3002\u6700\u540e\u88ab\u6d88\u8d39\u8005\u76d1\u542c\u6d88\u8d39\u3002\u5373\uff1a<strong>\u751f\u4ea7\u8005\u6295\u9012\u7684\u6d88\u606f\u7ecf\u8fc7\u4e00\u6bb5\u65f6\u95f4\u4e4b\u540e\u518d\u88ab\u6d88\u8d39\u8005\u6d88\u8d39<\/strong>\u3002<\/p>\n<p>\u5e38\u89c1\u4e1a\u52a1\u573a\u666f\uff1a\u8ba2\u5355\u572830\u5206\u949f\u5185\u8fd8\u672a\u652f\u4ed8\u5219\u81ea\u52a8\u53d6\u6d88\u3002<\/p>\n<p><!-- more --><\/p>\n<p>\u8be5\u4e1a\u52a1\u7684\u5176\u4ed6\u5b9e\u73b0\u65b9\u6848\uff1a<\/p>\n<ul>\n<li>\u4f7f\u7528Redis\uff0c\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\uff0c\u76d1\u542c\u8fc7\u671f\u4e8b\u4ef6\u3002<\/li>\n<li>\u4f7f\u7528RabbitMQ\u7684\u8fc7\u671f\u961f\u5217\u4e0e\u6b7b\u4fe1\u961f\u5217\uff0c\u8bbe\u7f6e\u6d88\u606f\u7684\u5b58\u6d3b\u65f6\u95f4\uff0c\u5728\u8bbe\u7f6e\u7684\u65f6\u95f4\u5185\u672a\u88ab\u6d88\u8d39\uff0c\u5373\u4f1a\u6295\u9012\u5230\u6b7b\u4fe1\u961f\u5217\uff0c\u6211\u4eec\u76d1\u542c\u6b7b\u4fe1\u961f\u5217\u5373\u53ef\u3002<\/li>\n<\/ul>\n<p>\u672c\u6587\u4ecb\u7ecd\u4f7f\u7528RabbitMQ\u5ef6\u8fdf\u961f\u5217\u6765\u5b9e\u73b0\u3002<\/p>\n<h2>RabbitMQ\u5ef6\u8fdf\u961f\u5217\u5b9e\u73b0<\/h2>\n<p>RabbitMQ\u5b9e\u73b0\u5ef6\u8fdf\u961f\u5217\u9700\u8981\u4f9d\u8d56\u63d2\u4ef6<code>rabbitmq-delayed-message-exchange<\/code>\u3002<\/p>\n<p>RabbitMQ\u63d2\u4ef6\u5217\u8868: <a target=\"_blank\" rel=\"noopener\" href=\"https:\/\/www.rabbitmq.com\/community-plugins.html\">https:\/\/www.rabbitmq.com\/community-plugins.html<\/a><br \/>\n\u5ef6\u8fdf\u961f\u5217\u63d2\u4ef6\u4e0b\u8f7d\u5730\u5740: <a target=\"_blank\" rel=\"noopener\" href=\"https:\/\/github.com\/rabbitmq\/rabbitmq-delayed-message-exchange\">https:\/\/github.com\/rabbitmq\/rabbitmq-delayed-message-exchange<\/a><\/p>\n<ul>\n<li>\u5c06\u4e0b\u8f7d\u7684\u63d2\u4ef6copy\u5230RabbitMQ\u7684plugins\u76ee\u5f55<\/li>\n<li>Mac\u4e0b\u7684\u63d2\u4ef6\u8def\u5f84\u4e3a<code>\/usr\/local\/rabbitmq\/3.8.7\/plugins<\/code><\/li>\n<li>\u5b89\u88c5\u5e76\u542f\u7528<\/li>\n<\/ul>\n<pre><code>rabbitmq-plugins enable rabbitmq_delayed_message_exchange<\/code><\/pre>\n<ul>\n<li>\u91cd\u542fRabbitMQ<\/li>\n<\/ul>\n<h2>\u4e1a\u52a1\u76f8\u5173\u4ee3\u7801\u7f16\u5199<\/h2>\n<p>\u5b9e\u73b0\u8ba2\u5355\u5728\u89c4\u5b9a\u7684\u65f6\u95f4\u5185\u8fd8\u672a\u652f\u4ed8\u5219\u8fc7\u671f<\/p>\n<ul>\n<li>\u8ba2\u5355\u5b9e\u4f53(\u4ec5\u4fdd\u7559\u76f8\u5173\u5b57\u6bb5)<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import com.baomidou.mybatisplus.annotation.IdType;\nimport com.baomidou.mybatisplus.annotation.TableField;\nimport com.baomidou.mybatisplus.annotation.TableId;\nimport com.baomidou.mybatisplus.annotation.TableName;\nimport lombok.Builder;\nimport lombok.Getter;\nimport lombok.Setter;\n\nimport java.time.LocalDateTime;\n\n\/**\n * \u8ba2\u5355\n *\/\n@Getter\n@Setter\n@Builder\n@TableName(&quot;t_order&quot;)\npublic class Order {\n\n    \/**\n     * \u4e3b\u952e\n     *\/\n    @TableId(value = &quot;id&quot;, type = IdType.UUID)\n    private String id;\n\n    \/**\n     * \u4e0b\u5355\u7528\u6237\u4e3b\u952e\n     *\/\n    @TableField(&quot;user_id&quot;)\n    private String userId;\n\n    \/**\n     * \u8ba2\u5355\u72b6\u6001\n     *\n     * @see OrderStatusEnum\n     *\/\n    @TableField(&quot;status&quot;)\n    private int status;\n\n    \/**\n     * \u652f\u4ed8\u65f6\u95f4\n     *\/\n    @TableField(&quot;pay_date_time&quot;)\n    private LocalDateTime payDateTime;\n\n    \/**\n     * \u8ba2\u5355\u8fc7\u671f\u65f6\u95f4\n     *\/\n    @TableField(&quot;expire_date_time&quot;)\n    private LocalDateTime expireDateTime;\n\n    \/**\n     * \u4e0b\u5355\u65f6\u95f4\n     *\/\n    @TableField(&quot;create_date_time&quot;)\n    private LocalDateTime createDateTime;\n}<\/code><\/pre>\n<ul>\n<li>\u8ba2\u5355\u72b6\u6001\u679a\u4e3e(\u4ec5\u4fdd\u7559\u76f8\u5173\u72b6\u6001)<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import lombok.AllArgsConstructor;\nimport lombok.Getter;\n\n\/**\n * \u8ba2\u5355\u72b6\u6001\n *\/\n@Getter\n@AllArgsConstructor\npublic enum OrderStatusEnum {\n\n    \/**\n     * 100=\u5f85\u652f\u4ed8\n     *\/\n    TO_BE_PAID(100, &quot;\u5f85\u652f\u4ed8&quot;),\n\n    \/**\n     * 200=\u5df2\u8fc7\u671f\n     *\/\n    EXPIRED(200, &quot;\u5df2\u8fc7\u671f&quot;),\n\n    \/**\n     * 300=\u5df2\u652f\u4ed8\n     *\/\n    PAID(300, &quot;\u5df2\u652f\u4ed8&quot;);\n\n    \/**\n     * \u8ba2\u5355\u72b6\u6001\n     *\/\n    private final int status;\n\n    \/**\n     * \u63cf\u8ff0\n     *\/\n    private final String description;\n\n}<\/code><\/pre>\n<ul>\n<li>OrderMapper<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import com.baomidou.mybatisplus.core.mapper.BaseMapper;\n\npublic interface OrderMapper extends BaseMapper&lt;Order&gt; {\n}<\/code><\/pre>\n<ul>\n<li>\u6a21\u62df\u4e0b\u5b9a\u7684\u63a5\u53e3OrderController\uff0c\u4e3a\u4e86\u7b80\u5355\u8d77\u89c1\uff0c\u7701\u7565\u4e86Service\u5c42<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import com.futao.springboot.learn.rabbitmq.doc.delaymessage.entity.Order;\nimport com.futao.springboot.learn.rabbitmq.doc.delaymessage.entity.OrderStatusEnum;\nimport com.futao.springboot.learn.rabbitmq.doc.delaymessage.mapper.OrderMapper;\nimport com.futao.springboot.learn.rabbitmq.doc.delaymessage.rabbitmq.OrderSender;\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.web.bind.annotation.PostMapping;\nimport org.springframework.web.bind.annotation.RequestMapping;\nimport org.springframework.web.bind.annotation.RestController;\n\nimport javax.annotation.Resource;\nimport java.time.LocalDateTime;\nimport java.time.ZoneOffset;\n\n\/**\n * \u8ba2\u5355\u63a5\u53e3\n *\/\n@RestController\n@RequestMapping(&quot;\/order&quot;)\npublic class OrderController {\n\n    @Resource\n    private OrderMapper orderMapper;\n\n    @Autowired\n    private OrderSender orderSender;\n\n    \/**\n     * \u4e0b\u5355\n     *\/\n    @PostMapping\n    public void add() {\n        Order order = Order\n                .builder()\n                .userId(&quot;joe&quot;)\n                \/\/\u5f85\u652f\u4ed8\n                .status(OrderStatusEnum.TO_BE_PAID.getStatus())\n                .createDateTime(LocalDateTime.now(ZoneOffset.ofHours(8)))\n                .build();\n        \/\/\u8ba2\u5355\u5165\u5e93\n        orderMapper.insert(order);\n        \/\/\u6295\u9012\u5ef6\u8fdf\u6d88\u606f\n        orderSender.send(order.getId());\n    }\n}<\/code><\/pre>\n<h2>RabbitMQ\u76f8\u5173\u4ee3\u7801\u7f16\u5199<\/h2>\n<ul>\n<li>\u914d\u7f6e\u6587\u4ef6<\/li>\n<\/ul>\n<pre><code class=\"language-yml\">spring:\n  rabbitmq:\n    host: localhost\n    port: 5672\n    username: futao\n    password: 123456789\n    virtual-host: delay-vh\n    connection-timeout: 15000\n    # \u53d1\u9001\u786e\u8ba4\n    publisher-confirms: true\n    # \u8def\u7531\u5931\u8d25\u56de\u8c03\n    publisher-returns: true\n    template:\n      # \u5fc5\u987b\u8bbe\u7f6e\u6210true \u6d88\u606f\u8def\u7531\u5931\u8d25\u901a\u77e5\u76d1\u542c\u8005\uff0c\u800c\u4e0d\u662f\u5c06\u6d88\u606f\u4e22\u5f03\n      mandatory: true\n    listener:\n      simple:\n        # \u6bcf\u6b21\u4eceRabbitMQ\u83b7\u53d6\u7684\u6d88\u606f\u6570\u91cf\n        prefetch: 1\n        default-requeue-rejected: false\n        # \u6bcf\u4e2a\u961f\u5217\u542f\u52a8\u7684\u6d88\u8d39\u8005\u6570\u91cf\n        concurrency: 1\n        # \u6bcf\u4e2a\u961f\u5217\u6700\u5927\u7684\u6d88\u8d39\u8005\u6570\u91cf\n        max-concurrency: 1\n        # \u624b\u52a8\u7b7e\u6536ACK\n        acknowledge-mode: manual\n\napp:\n  rabbitmq:\n    # \u5ef6\u8fdf\u65f6\u957f\u8bbe\u7f6e\n    delay:\n      order: 10S\n    # \u961f\u5217\u5b9a\u4e49\n    queue:\n      order:\n        delay: order-delay-queue\n    # \u4ea4\u6362\u673a\u5b9a\u4e49\n    exchange:\n      order:\n        delay: order-delay-exchange<\/code><\/pre>\n<ul>\n<li>\u5ef6\u8fdf\u4ea4\u6362\u673a\uff0c\u961f\u5217\u5b9a\u4e49\u4e0e\u7ed1\u5b9a<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import org.springframework.amqp.core.*;\nimport org.springframework.beans.factory.annotation.Value;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Configuration;\n\nimport java.util.HashMap;\nimport java.util.Map;\n\n\/**\n * \u961f\u5217\uff0c\u4ea4\u6362\u673a\u5b9a\u4e49\u4e0e\u7ed1\u5b9a\n * \u5ef6\u8fdf\u961f\u5217\u63d2\u4ef6`rabbitmq-delayed-message-exchange`\u4e0b\u8f7d\u5730\u5740 https:\/\/github.com\/rabbitmq\/rabbitmq-delayed-message-exchange\n *\/\n@Configuration\npublic class Declare {\n\n    \/**\n     * \u8ba2\u5355\u961f\u5217 - \u63a5\u6536\u5ef6\u8fdf\u6295\u9012\u7684\u8ba2\u5355\n     *\n     * @param orderQueue \u8ba2\u5355\u961f\u5217\u540d\u79f0\n     * @return\n     *\/\n    @Bean\n    public Queue orderDelayQueue(@Value(&quot;${app.rabbitmq.queue.order.delay}&quot;) String orderQueue) {\n        return QueueBuilder\n                .durable(orderQueue)\n                .build();\n    }\n\n    \/**\n     * \u8ba2\u5355\u4ea4\u6362\u673a-\u5ef6\u8fdf\u4ea4\u6362\u673a - \u6d88\u606f\u5ef6\u8fdf\u4e00\u5b9a\u65f6\u95f4\u4e4b\u540e\u518d\u6295\u9012\u5230\u7ed1\u5b9a\u7684\u961f\u5217\n     *\n     * @param orderExchange \u8ba2\u5355\u5ef6\u8fdf\u4ea4\u6362\u673a\n     * @return\n     *\/\n    @Bean\n    public Exchange orderDelayExchange(@Value(&quot;${app.rabbitmq.exchange.order.delay}&quot;) String orderExchange) {\n        Map&lt;String, Object&gt; args = new HashMap&lt;&gt;(1);\n        args.put(&quot;x-delayed-type&quot;, &quot;topic&quot;);\n        return new CustomExchange(orderExchange, &quot;x-delayed-message&quot;, true, false, args);\n    }\n\n    \/**\n     * \u8ba2\u5355\u961f\u5217-\u4ea4\u6362\u673a \u7ed1\u5b9a\n     *\n     * @param orderQueue         \u8ba2\u5355\u961f\u5217\n     * @param orderDelayExchange \u8ba2\u5355\u4ea4\u6362\u673a\n     * @return\n     *\/\n    @Bean\n    public Binding orderBinding(Queue orderDelayQueue, Exchange orderDelayExchange) {\n        return BindingBuilder\n                .bind(orderDelayQueue)\n                .to(orderDelayExchange)\n                .with(&quot;order.delay.*&quot;)\n                .noargs();\n    }\n\n}<\/code><\/pre>\n<p>\u53ef\u4ee5\u770b\u51fa\u961f\u5217\u5c31\u662f\u666e\u901a\u7684\u961f\u5217\uff0c\u91cd\u70b9\u5728\u4ea4\u6362\u673a\u7684\u8bbe\u5b9a\u4e0a\u3002\u58f0\u660e\u5ef6\u8fdf\u4ea4\u6362\u673a\u9700\u8981\u8bbe\u7f6e\u53c2\u6570<code>x-delayed-type<\/code>\uff0c\u503c\u4e3a\u4ea4\u6362\u673a\u7c7b\u578b\uff0c\u53ef\u4ee5\u662f<code>fanout,topic,direct<\/code>\u3002\u5e76\u4e14\u8bbe\u7f6e\u4ea4\u6362\u673a\u7684type\u4e3a<code>x-delayed-message<\/code>\u3002<\/p>\n<p>\u5b9a\u4e49\u5b8c\u6210\u540e\u53ef\u4ee5\u542f\u52a8Spring Boot\u5e94\u7528\u7a0b\u5e8f\uff0c\u5728RabbitMQ\u7ba1\u7406\u540e\u53f0\u67e5\u770b<code>Exchange<\/code>\u548c<code>Queue<\/code>\u3002<\/p>\n<p><img decoding=\"async\" src=\"http:\/\/www.yezhou.me\/AppBlog\/images\/Java\/rabbitmq-delay-exchange.png\" alt=\"rabbitmq-delay-exchange\" \/><\/p>\n<p>\u53ef\u4ee5\u770b\u5230\uff0c\u9664\u4e86\u9ed8\u8ba4\u7684\u4ea4\u6362\u673a\uff0cSpring Boot\u5df2\u7ecf\u5e2e\u6211\u4eec\u521b\u5efa\u597d\u4e86\u5ef6\u8fdf\u4ea4\u6362\u673a<code>order-delay-exchange<\/code>\uff0c\u5e76\u4e14\u6b64\u65f6<code>messages delayed<\/code>\u4e3a0\uff0c\u56e0\u4e3a\u6211\u4eec\u8fd8\u672a\u5411\u4ea4\u6362\u673a\u6295\u9012\u6d88\u606f\u3002<\/p>\n<ul>\n<li>\u53ef\u4ee5\u7ee7\u7eed\u67e5\u770b\u4ea4\u6362\u673a\u7684\u8def\u7531\u7c7b\u578b\u4e0e\u7ed1\u5b9a\u7684\u961f\u5217<\/li>\n<\/ul>\n<p><img decoding=\"async\" src=\"http:\/\/www.yezhou.me\/AppBlog\/images\/Java\/rabbitmq-exchange-detail.png\" alt=\"rabbitmq-exchange-detail\" \/><\/p>\n<ul>\n<li>\u5728\u67e5\u770b\u961f\u5217\uff0c\u4e3a\u666e\u901a\u7684\u961f\u5217<\/li>\n<\/ul>\n<p><img decoding=\"async\" src=\"http:\/\/www.yezhou.me\/AppBlog\/images\/Java\/rabbitmq-queue-detail.png\" alt=\"rabbitmq-queue-detail\" \/><\/p>\n<ul>\n<li>\u56de\u5230\u4ee3\u7801\u4e2d\uff0c\u5b9a\u4e49\u6d88\u606f\u751f\u4ea7\u8005<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import lombok.extern.slf4j.Slf4j;\nimport org.springframework.amqp.core.MessageProperties;\nimport org.springframework.amqp.rabbit.core.RabbitTemplate;\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.beans.factory.annotation.Value;\nimport org.springframework.stereotype.Component;\n\nimport java.time.Duration;\n\n@Slf4j\n@Component\npublic class OrderSender {\n\n    \/**\n     * \u8ba2\u5355\u5ef6\u8fdf\u65f6\u957f\n     *\/\n    @Value(&quot;${app.rabbitmq.delay.order}&quot;)\n    private Duration delayTime;\n\n    \/**\n     * \u8ba2\u5355\u5ef6\u8fdf\u4ea4\u6362\u673a\u540d\u79f0\n     *\/\n    @Value(&quot;${app.rabbitmq.exchange.order.delay}&quot;)\n    private String orderExchange;\n\n    @Autowired\n    private RabbitTemplate rabbitTemplate;\n\n    \/**\n     * \u8ba2\u5355\u4fe1\u606f\u6295\u9012\u5230\u5ef6\u8fdf\u4ea4\u6362\u673a\n     *\n     * @param orderId \u8ba2\u5355\u4e3b\u952e\n     *\/\n    public void send(String orderId) {\n        rabbitTemplate.convertAndSend(orderExchange, &quot;order.delay.abc&quot;, orderId, message -&gt; {\n            MessageProperties messageProperties = message.getMessageProperties();\n            \/\/\u8bbe\u7f6e\u6d88\u606f\u7684\u5ef6\u8fdf\u6295\u9012\u65f6\u95f4\n            messageProperties.setDelay((int) delayTime.toMillis());\n            return message;\n        });\n        log.info(&quot;\u8ba2\u5355[{}]\u6295\u9012\u5230MQ&quot;, orderId);\n    }\n}<\/code><\/pre>\n<p>\u5728\u6d88\u606f\u6295\u9012\u4e4b\u524d\u4e3a\u6bcf\u6761\u6d88\u606f\u90fd\u8bbe\u7f6e\u4e86\u5ef6\u8fdf\u65f6\u957f<code>setDelay()<\/code>\u3002\u8c03\u7528\u6d88\u8d39\u8005\u7684\u4ee3\u7801\u5728\u4e0a\u9762<code>OrderController<\/code>\u4e2d\uff0c\u4e0b\u5b9a\u4e4b\u540e\uff0c\u8ba2\u5355\u6570\u636e\u843d\u5e93\uff0c\u5e76\u4e14\u5411MQ\u4e2d\u6295\u9012\u5ef6\u8fdf\u6d88\u606f\u3002<\/p>\n<ul>\n<li>\u6d88\u8d39\u8005\uff1a\u76d1\u542c\u8fc7\u671f\u7684\u8ba2\u5355\u4fe1\u606f\uff0c\u5e76\u4e14\u5c06DB\u4e2d\u76f8\u5e94\u7684\u8ba2\u5355\u8bbe\u7f6e\u4e3a\u5df2\u8fc7\u671f\u3002<\/li>\n<\/ul>\n<pre><code class=\"language-java\">import com.baomidou.mybatisplus.core.toolkit.Wrappers;\nimport com.futao.springboot.learn.rabbitmq.doc.delaymessage.entity.Order;\nimport com.futao.springboot.learn.rabbitmq.doc.delaymessage.entity.OrderStatusEnum;\nimport com.futao.springboot.learn.rabbitmq.doc.delaymessage.mapper.OrderMapper;\nimport com.rabbitmq.client.Channel;\nimport lombok.extern.slf4j.Slf4j;\nimport org.springframework.amqp.core.Message;\nimport org.springframework.amqp.rabbit.annotation.RabbitListener;\nimport org.springframework.stereotype.Component;\n\nimport javax.annotation.Resource;\nimport java.io.IOException;\nimport java.time.LocalDateTime;\nimport java.time.ZoneOffset;\nimport java.util.concurrent.TimeUnit;\n\n\/**\n * \u5ef6\u8fdf\u8ba2\u5355\u76d1\u542c\n *\/\n@Slf4j\n@Component\npublic class OrderConsumer {\n\n    @Resource\n    private OrderMapper orderMapper;\n\n    \/**\n     * \u5ef6\u8fdf\u8ba2\u5355\u76d1\u542c\uff0c\u8bbe\u7f6e\u8ba2\u5355\u4e3a\u5df2\u8fc7\u671f\n     *\n     * @param orderId\n     * @param channel\n     * @param message\n     * @throws IOException\n     *\/\n    @RabbitListener(queues = &quot;${app.rabbitmq.queue.order.delay}&quot;)\n    public void consumer(String orderId, Channel channel, Message message) throws IOException, InterruptedException {\n        log.info(&quot;\u6d88\u8d39\u8005\u63a5\u6536\u5230\u5ef6\u8fdf\u8ba2\u5355[{}]&quot;, orderId);\n        \/\/\u5c06\u8ba2\u5355\u72b6\u6001\u8bbe\u7f6e\u6210\u5df2\u8d85\u65f6\u8fc7\u671f\n        orderMapper.update(null,\n                Wrappers.&lt;Order&gt;lambdaUpdate()\n                        .eq(Order::getId, orderId)\n                        \/\/\u5f85\u652f\u4ed8\u72b6\u6001\n                        .eq(Order::getStatus, OrderStatusEnum.TO_BE_PAID.getStatus())\n                        \/\/\u8bbe\u7f6e\u6210\u5df2\u8fc7\u671f\n                        .set(Order::getStatus, OrderStatusEnum.EXPIRED.getStatus())\n                        \/\/\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\n                        .set(Order::getExpireDateTime, LocalDateTime.now(ZoneOffset.ofHours(8)))\n        );\n        log.info(&quot;\u8ba2\u5355\u4e1a\u52a1\u5904\u7406\u7ed3\u675f.....\u8fdb\u884c\u6d88\u606fack\u7b7e\u6536&quot;);\n        \/\/msg ack\n        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);\n    }\n}<\/code><\/pre>\n<p>\u4e3a\u4e86\u65b9\u4fbf\u67e5\u770b\u5230\u5ef6\u8fdf\u6295\u9012\u7684\u6548\u679c\uff0c\u5728\u6d88\u606f\u6295\u9012\u548c\u63a5\u6536\u5904\u90fd\u6253\u5370\u4e86\u65e5\u5fd7\uff0c\u6d4b\u8bd5\u65f6\u53ef\u4ee5\u770b\u5230\u6d88\u606f\u6295\u9012\u548c\u6d88\u606f\u7684\u65f6\u95f4\u95f4\u9694\u3002<\/p>\n<h2>\u6d4b\u8bd5<\/h2>\n<p>\u628a\u8ba2\u5355\u8fc7\u671f\u65f6\u957f\u8bbe\u7f6e\u4e3a10S<\/p>\n<pre><code class=\"language-yml\">app:\n  rabbitmq:\n    delay:\n      order: 10S<\/code><\/pre>\n<p>\u4e0b\u5355<\/p>\n<pre><code>2020-05-15 22:22:05.387  INFO 72852  OrderSender       : \u8ba2\u5355[666ae86aabe2a1b3120b34bb5f447bbe]\u6295\u9012\u5230MQ<\/code><\/pre>\n<p>\u53ef\u4ee5\u770b\u5230\uff0c\u6253\u5370\u51fa\u4e86\u6295\u9012\u65e5\u5fd7\uff0c\u8ba2\u5355\u4e3b\u952e\u4e3a<code>666ae86aabe2a1b3120b34bb5f447bbe<\/code>\u7684\u8ba2\u5355\u5728<code>2020-05-15 22:22:05.387<\/code>\u8fdb\u884c\u4e86\u6295\u9012\uff0c\u6b64\u65f6\u6570\u636e\u5e93\u4e2d\u8be5\u8ba2\u5355\u7684\u72b6\u6001\u4e3a100\uff0c\u5f85\u652f\u4ed8\u3002<\/p>\n<p>\u6b64\u65f6\u67e5\u770brabbitMQ\u63a7\u5236\u53f0Exchange\u8be6\u60c5\u53ef\u4ee5\u53d1\u73b0\uff0c<code>messages delayed:1<\/code>\uff0c\u5373\u76ee\u524d\u6709\u4e00\u6761\u6d88\u606f\u5904\u4e8e\u5ef6\u8fdf\u72b6\u6001\u3002<\/p>\n<p>\u7b49\u5f8510S\u540e<\/p>\n<pre><code>2020-05-15 22:22:05.387  OrderSender       : \u8ba2\u5355[666ae86aabe2a1b3120b34bb5f447bbe]\u6295\u9012\u5230MQ\n2020-05-15 22:22:15.320  OrderConsumer     : \u6d88\u8d39\u8005\u63a5\u6536\u5230\u5ef6\u8fdf\u8ba2\u5355[666ae86aabe2a1b3120b34bb5f447bbe]<\/code><\/pre>\n<p>\u53ef\u4ee5\u770b\u5230OrderConsumer\u572810S\u540e<code>2020-05-15 22:22:15.320<\/code>\u63a5\u6536\u5230\u4e86\u4e3b\u952e\u4e3a<code>666ae86aabe2a1b3120b34bb5f447bbe<\/code>\u7684\u8ba2\u5355\u6d88\u606f\u3002\u8ddd\u79bb\u6295\u9012\u65f6\u95f4<code>2020-05-15 22:22:05.387<\/code>\u4e3a10S\u3002\u6b64\u65f6\u67e5\u770bDB\u4e2d\u8ba2\u5355\u72b6\u6001\uff0c\u8ba2\u5355\u72b6\u6001\u4e3a200\u5df2\u8fc7\u671f\uff0c\u4e14\u8fc7\u671f\u65f6\u95f4\u4e3a<code>2020-05-15 22:22:15<\/code><\/p>\n<p>\u8fbe\u5230\u4e86\u8ba2\u5355\u5728\u6211\u4eec\u6307\u5b9a\u7684\u65f6\u95f4\u540e\u8fc7\u671f\u3002<\/p>\n<h2>\u4e25\u91cd\u98ce\u9669\u63d0\u793a<\/h2>\n<blockquote>\n<p>\u5728\u5b9e\u9645\u4e1a\u52a1\u4f7f\u7528\u4e2d\uff0c\u5982\u679c\u6d88\u8d39\u8005\u7684\u6d88\u8d39\u80fd\u529b\u6bd4\u8f83\u4f4e\u4e0b\uff0c\u4f1a\u5b58\u5728\u5df2\u7ecf\u8fc7\u671f\u7684\u6d88\u606f\u963b\u585e\u79ef\u538b\u5728\u961f\u5217\uff0c\u65e0\u6cd5\u5728\u6307\u5b9a\u7684\u65f6\u95f4\u5185\u8fc7\u671f\uff0c\u5bfc\u81f4\u4e1a\u52a1\u51fa\u73b0\u5f02\u5e38\u3002\u5b9e\u9645\u4e0a\uff0c\u6309\u7167\u6211\u4eec\u4e1a\u52a1\u610f\u56fe\uff0c\u961f\u91ccQueue\u91cc\u662f\u4e0d\u5e94\u8be5\u6709\u5927\u91cf\u6d88\u606f\u5b58\u5728\u7684\uff0c\u56e0\u4e3a\u6295\u9012\u5230\u8fc7\u671f\u961f\u5217\u7684\u6d88\u606f\u5df2\u7ecf\u662f\u8fc7\u671f\u4e86\u7684\uff0c\u5e94\u8be5\u7acb\u5373\u88ab\u6d88\u8d39\u6389\u3002<\/p>\n<\/blockquote>\n<p>\u4e3a\u4e86\u964d\u4f4e\u6d88\u8d39\u8005\u7684\u6d88\u8d39\u80fd\u529b\uff0c\u8fdb\u884c\u5982\u4e0b\u5904\u7406\uff1a<\/p>\n<p>\uff081\uff09\u8bbe\u7f6e\u6d88\u8d39\u8005\u7684\u6700\u5927\u5e76\u53d1\u6570\u4e3a1\uff0c\u5e76\u8fdb\u884c\u624b\u52a8\u7b7e\u6536\u3002<\/p>\n<pre><code class=\"language-yml\">spring:\n  rabbitmq:\n    ...\n    listener:\n      simple:\n        # \u6bcf\u4e2a\u961f\u5217\u542f\u52a8\u7684\u6d88\u8d39\u8005\u6570\u91cf\n        concurrency: 1\n        # \u6bcf\u4e2a\u961f\u5217\u6700\u5927\u7684\u6d88\u8d39\u8005\u6570\u91cf\n        max-concurrency: 1\n        acknowledge-mode: manual\n\napp:\n  rabbitmq:\n    delay:\n      # \u8ba2\u5355\u8fc7\u671f\u65f6\u95f4\u4e3a1\u5206\u949f\n      order: 1M<\/code><\/pre>\n<p>\uff082\uff09\u6d88\u8d39\u8005\u5728\u5904\u7406\u6d88\u606f\u65f6\u4f11\u772010S<\/p>\n<pre><code class=\"language-java\">RabbitListener(queues = &quot;${app.rabbitmq.queue.order.delay}&quot;)\npublic void consumer(String orderId, Channel channel, Message message) throws IOException, InterruptedException {\n    log.info(&quot;\u6d88\u8d39\u8005\u63a5\u6536\u5230\u5ef6\u8fdf\u8ba2\u5355[{}]&quot;, orderId);\n    \/\/\u5c06\u8ba2\u5355\u72b6\u6001\u8bbe\u7f6e\u6210\u5df2\u8d85\u65f6\u8fc7\u671f\n    orderMapper.update(null,\n            Wrappers.&lt;Order&gt;lambdaUpdate()\n                    .eq(Order::getId, orderId)\n                    \/\/\u5f85\u652f\u4ed8\u72b6\u6001\n                    .eq(Order::getStatus, OrderStatusEnum.TO_BE_PAID.getStatus())\n                    \/\/\u8bbe\u7f6e\u6210\u5df2\u8fc7\u671f\n                    .set(Order::getStatus, OrderStatusEnum.EXPIRED.getStatus())\n                    \/\/\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\n                    .set(Order::getExpireDateTime, LocalDateTime.now(ZoneOffset.ofHours(8)))\n    );\n    TimeUnit.SECONDS.sleep(10);  \/\/\u4f11\u772010S\n    log.info(&quot;\u8ba2\u5355\u4e1a\u52a1\u5904\u7406\u7ed3\u675f.....\u8fdb\u884c\u6d88\u606fack\u7b7e\u6536&quot;);\n    \/\/msg ack\n    channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);\n}<\/code><\/pre>\n<p>\uff083\uff09\u5411MQ\u6295\u9012\u4e24\u6761\u6d88\u606f\uff0c\u9884\u671f\u4e24\u6761\u6d88\u606f\u90fd\u57281\u5206\u949f\u540e\u6b63\u5e38\u8fc7\u671f<\/p>\n<p>\uff084\uff09\u8f93\u51fa\u65e5\u5fd7\uff1a<\/p>\n<pre><code>2020-05-15 20:18:05.269  OrderSender       : \u8ba2\u5355[d6fd965b11f8db0fafb762d305db83b0]\u6295\u9012\u5230MQ\n2020-05-15 20:18:05.765  OrderSender       : \u8ba2\u5355[77ceb7f1bfbbcaf627224ac75e96b0e5]\u6295\u9012\u5230MQ\n\n2020-05-15 20:19:05.279  OrderConsumer     : \u6d88\u8d39\u8005\u63a5\u6536\u5230\u5ef6\u8fdf\u8ba2\u5355[d6fd965b11f8db0fafb762d305db83b0]\n2020-05-15 20:19:15.316  OrderConsumer     : \u8ba2\u5355\u4e1a\u52a1\u5904\u7406\u7ed3\u675f.....\u8fdb\u884c\u6d88\u606fack\u7b7e\u6536\n\n2020-05-15 20:19:15.318  OrderConsumer     : \u6d88\u8d39\u8005\u63a5\u6536\u5230\u5ef6\u8fdf\u8ba2\u5355[77ceb7f1bfbbcaf627224ac75e96b0e5]\n2020-05-15 20:19:25.330  OrderConsumer     : \u8ba2\u5355\u4e1a\u52a1\u5904\u7406\u7ed3\u675f.....\u8fdb\u884c\u6d88\u606fack\u7b7e\u6536<\/code><\/pre>\n<p>\u7b2c\u4e00\u4e2a\u8ba2\u5355<code>d6fd965b11f8db0fafb762d305db83b0<\/code>\u6295\u9012\u65f6\u95f4\u4e3a<code>2020-05-15 20:18:05.269<\/code>\u30021\u5206\u949f\u540e<code>2020-05-15 20:19:05.279<\/code>\u63a5\u6536\u5230\u4e86\u901a\u77e5\uff0c\u5e76\u4e14\u5904\u7406\u4e8610S\u540e\u8fdb\u884c\u4e86\u7b7e\u6536ack \u7b2c\u4e8c\u4e2a\u8ba2\u5355<code>77ceb7f1bfbbcaf627224ac75e96b0e5<\/code>\u6295\u9012\u65f6\u95f4\u4e3a<code>2020-05-15 20:18:05.765<\/code>\u30021\u5206\u949f\u8fc7\u540e\u5e76\u6ca1\u6709\u6536\u5230\u901a\u77e5\uff0c\u800c\u662f\u5728\u7b2c\u4e00\u4e2a\u8ba2\u5355\u5904\u7406\u5b8c\u6bd5\u4e4b\u540e\uff0c<code>2020-05-15 20:19:15.318<\/code>\u624d\u6536\u5230\u4e86\u901a\u77e5\uff0c\u6bd4\u9884\u671f\u7684\u65f6\u95f4\u957f\u4e8610\u79d2\uff0c\u5b9e\u9645\u5ef6\u8fdf\u65f6\u95f4\u4e3a1\u5206\u949f+10\u79d2\u3002\u51fa\u73b0\u4e86\u4e1a\u52a1\u5f02\u5e38<\/p>\n<p>\u5bfc\u81f4\u8fd9\u4e2a\u95ee\u9898\u7684\u539f\u56e0\u5c31\u662f\u6d88\u8d39\u8005\u65e0\u6cd5\u53ca\u65f6\u6d88\u8d39\u6d88\u606f\u5e76\u66f4\u65b0\u8ba2\u5355\u72b6\u6001\u3002\u6240\u4ee5\u6211\u4eec\u5728\u8fdb\u884c\u5f00\u53d1\u65f6\uff0c\u9700\u8981\u8003\u8651\u5b9e\u9645\u7684\u6570\u636e\u91cf\u5927\u5c0f\uff0c\u6d88\u8d39\u8005\u6d88\u8d39\u80fd\u529b\u3002\u53ca\u65f6\u5173\u6ce8\u961f\u5217\u6d88\u606f\u79ef\u538b\u60c5\u51b5\uff0c\u7075\u6d3b\u8c03\u6574\u6d88\u8d39\u8005\u5e76\u53d1\u6570\u91cf\uff0c\u4f18\u5316\u6d88\u8d39\u8005\u4ee3\u7801\uff0c\u63d0\u9ad8\u6d88\u8d39\u8005\u6d88\u8d39\u80fd\u529b\uff0c\u4fdd\u8bc1\u4ee3\u7801\u7684\u6267\u884c\u7ed3\u679c\u7b26\u5408\u6211\u4eec\u7684\u9884\u671f\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"<p>RabbitMQ\u5ef6\u8fdf\u961f\u5217\u5e94\u7528 \u5ef6\u8fdf\u961f\u5217\u53ef\u4ee5\u5b9e\u73b0\u6d88\u606f\u5728\u6295\u9012\u5230Exchange\u4e4b\u540e\uff0c\u7ecf\u8fc7\u4e00\u5b9a\u7684\u65f6\u95f4\u4e4b\u540e\u518d\u8def\u7531\u5230\u76f8\u5e94 [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[32],"tags":[],"class_list":["post-1785","post","type-post","status-publish","format-standard","hentry","category-rabbitmq"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1785","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1785"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1785\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1785"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1785"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1785"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}