<dependency>
   <groupId>org.springframework.amqp</groupId>
   <artifactId>spring-amqp</artifactId>
   <version>1.6.0.RELEASE</version>
  </dependency>
  <dependency>
   <groupId>org.springframework.amqp</groupId>
   <artifactId>spring-rabbit</artifactId>
   <version>1.6.0.RELEASE</version>
  </dependency> 

<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/rabbit"
    xmlns:beans="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/rabbit
    http://www.springframework.org/schema/rabbit/spring-rabbit.xsd
    http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans.xsd">
 <!--1、配置連接工廠, 如果不配置host, port, username, passowrd, 則按默認值localhost:5672, guest/guest-->
 <!--<connection-factory id="connectionFactory" />-->
 <connection-factory id="connectionFactory"
      host="localhost"
      port="5672"
      username="everSeeker"
      password="333" />
 <!--2、配置隊列queue, Exchange, 以及將他們結(jié)合在一起的binding-->
 <!--在queue以及exchange中, 有一個重要的屬性durable, 默認為true, 可以防止宕機后數(shù)據(jù)丟失。-->
 <!--在listener-container中, 有acknowledge屬性, 默認為auto, 即消費者成功處理消息后必須有個應答, 如果消費者程序發(fā)生異?；蛘咤礄C, 消息會被重新放回隊列-->
 <admin connection-factory="connectionFactory" />
 <queue id="userAlertEmailQueue" name="user.alerts.email" durable="true" />
 <queue id="userAlertCellphoneQueue" name="user.alerts.cellphone" />  <!--durable默認為true-->
 <!--標準的AMQP Exchange有4種: Direct, Topic, Headers, Fanout, 根據(jù)實際需要選擇。-->
 <!--Direct: 如果消息的routing key與bingding的routing key直接匹配的話, 消息將會路由到該隊列上。-->
 <!--Topic: 如果消息的routing key與bingding的routing key符合通配符匹配的話, 消息將會路由到該隊列上。-->
 <!--Headers: 如果消息參數(shù)表中的頭信息和值都與binding參數(shù)表中相匹配, 消息將會路由到該隊列上。-->
 <!--Fanout: 不管消息的routing key和參數(shù)表的頭信息/值是什么, 消息將會路由到該隊列上。-->
 <direct-exchange name="user.alert.email.exchange" durable="true">
  <bindings>
   <binding queue="user.alerts.email" />  <!--默認的routing key與隊列的名稱相同-->
  </bindings>
 </direct-exchange>
 <direct-exchange name="user.alert.cellphone.exchange">
  <bindings>
   <binding queue="user.alerts.cellphone" />
  </bindings>
 </direct-exchange>
 <!--3、配置RabbitTemplate發(fā)送消息-->
 <template id="rabbitTemplate"
    connection-factory="connectionFactory" />
 <!--4、配置監(jiān)聽器容器和監(jiān)聽器來接收消息-->
 <beans:bean id="userListener" class="com.everSeeker.alerts.UserAlertHandler" />
 <listener-container connection-factory="connectionFactory" acknowledge="auto">
  <listener ref="userListener"
     method="handleUserAlertToEmail"
     queues="userAlertEmailQueue" />
  <listener ref="userListener"
     method="handleUserAlertToCellphone"
     queues="userAlertCellphoneQueue" />
 </listener-container>
</beans:beans> 

@Service("userAlertService")
public class UserAlertServiceImpl implements UserAlertService {
 private RabbitTemplate rabbit;
 @Autowired
 public UserAlertServiceImpl(RabbitTemplate rabbit) {
  this.rabbit = rabbit;
 }
 public void sendUserAlertToEmail(User user) {
  //convertAndSend(String exchange, String routingKey, Object object), 將對象object封裝成Message對象后, 發(fā)送給exchange
  rabbit.convertAndSend("user.alert.email.exchange", "user.alerts.email", user);
 }
} 

public class UserAlertHandler {
 public void handleUserAlertToEmail(User user) {
  System.out.println(user);
}

<dependency>
 <groupId>javax.mail</groupId>
 <artifactId>mail</artifactId>
 <version>1.4.7</version>
</dependency> 

@Bean
public MailSender mailSender(Environment env) {
 JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
 //如果為普通郵箱, 非ssl認證等, 比如163郵箱
 mailSender.setHost(env.getProperty("mailserver.host"));
 mailSender.setPort(Integer.parseInt(env.getProperty("mailserver.port")));
 mailSender.setUsername(env.getProperty("mailserver.username"));
 mailSender.setPassword(env.getProperty("mailserver.password"));
 mailSender.setDefaultEncoding("utf-8");
 //如果郵件服務器采用了ssl認證, 增加以下配置, 比如gmail郵箱, qq郵箱
 Properties props = new Properties();
 props.put("mail.smtp.auth", "true");
 props.put("mail.smtp.starttls.enable", "true");
 props.put("mail.smtp.socketFactory.class","javax.net.ssl.SSLSocketFactory");
 props.put("mail.smtp.socketFactory.port", "465");
 mailSender.setJavaMailProperties(props);
 return mailSender;
} 

@Component("userMailService")
public class UserMailServiceImpl implements UserMailService {
 private MailSender mailSender;
 @Autowired
 public UserMailServiceImpl(MailSender mailSender) {
  this.mailSender = mailSender;
 }
 public void sendSimpleUserMail(String to, User user) {
  SimpleMailMessage message = new SimpleMailMessage();
  message.setFrom("xxxxxxxx@qq.com");
  message.setTo(to);
  message.setSubject(user.getUsername() + "信息確認");
  message.setText(user.toString());
  mailSender.send(message);
 }
}