SSM (JDK 1.7) 使用Rabbit MQ

※ rabbitMq各版本与jdk适配不一样, 本文指定适配jdk1.7，所以使用了4.12.0版本。其他JDK请自行适配对应jar包版本

rabbit 4.x 最低适配 jdk1.6
rabbit 5.x 最低适配 jdk1.8

package com.yc.ssm.framwork.mq;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import java.nio.charset.StandardCharsets;


public class WorkOrderListener implements MessageListener {
    @Autowired
    RabbitTemplate rabbitTemplate;

    @Override
    public void onMessage(Message message) {
        try {
            String body = new String(message.getBody(), StandardCharsets.UTF_8);
            System.out.println("[work.order.queue] 队列消息 : " + body);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

package com.yc.ssm.framwork.mq;

import com.alibaba.fastjson.JSON;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;


@Component
public class MqWorkOrderSender {
    private final Logger logger = LoggerFactory.getLogger(MqWorkOrderSender.class);

    @Autowired
    private RabbitTemplate rabbitTemplate;
	
	
	public void send(String routeKey, Object data) {
		rabbitTemplate.convertAndSend(routeKey, data);
	}

	
    public void convertAndSendAtDelay(String exchange, String routeKey, Object data, final long delayTime) {
        rabbitTemplate.convertAndSend(exchange, routeKey, data,
                new MessagePostProcessor() {
                    @Override
                    public Message postProcessMessage(Message message) throws AmqpException {
                        //给消息设置延迟毫秒值
                        message.getMessageProperties().setTimestamp(new Date());
                        message.getMessageProperties().setExpiration(String.valueOf(delayTime));
                        return message;
                    }
                });
        logger.info("send delay object: {}", JSON.toJSONString(data));
    }
}

  cyy
  
    contextConfigLocation
    
        classpath*:/applicationContext*.xml,
        classpath*:/spring-*.xml
    
  
  
    spring.profiles.default
    test
  
  
    shiroFilter
    org.springframework.web.filter.DelegatingFilterProxy
    
      targetFilterLifecycle
      true
    
  
  
    shiroFilter
    /*
    REQUEST
    FORWARD
  
  
    encodingFilter
    org.springframework.web.filter.CharacterEncodingFilter
    
      encoding
      UTF-8
    
    
      forceEncoding
      true
    
  
  
    encodingFilter
    /*
  
  
    org.springframework.web.util.IntrospectorCleanupListener
  
  
    org.springframework.web.context.ContextLoaderListener
  
  
    60
  
  
    springMvc
    org.springframework.web.servlet.DispatcherServlet
    
      contextConfigLocation
      classpath:springMvc.xml
    
    1
  
  
    springMvc
    /
  
  
    captcha
    com.google.code.kaptcha.servlet.KaptchaServlet
  
  
    captcha
    /static/captcha.jpg
  
  
    DruidStatView
    com.alibaba.druid.support.http.StatViewServlet
  
  
    DruidStatView
    /druid/*
  
  
    default.jsp
    index.jsp
  
  
    
      *.jsp
      UTF-8
      false
      true