ActivemMQ之消息服务器平台（发邮件）详解编程语言

package com.toov5.Producer; 
 
import javax.jms.Queue; 
 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.jms.core.JmsMessagingTemplate; 
import org.springframework.scheduling.annotation.Scheduled; 
import org.springframework.stereotype.Component; 
 
import com.alibaba.fastjson.JSONObject; 
 
@Component 
public class P2PProducer { 
    @Autowired 
    private JmsMessagingTemplate jmsMessagingTemplate; 
    //把队列注入进来  
    @Autowired  //此注解默认是以类型找  在配置文件中 已经注入的  @Bean  
    private Queue queue; 
     
    //每隔5s时间向队列发送消息 
    @Scheduled(fixedDelay=5000)  //每间隔2s向队列发送消息 
    public void send() { 
        String userName = System.currentTimeMillis()+" "; 
            JSONObject jsonObject  = new JSONObject(); 
            jsonObject.put("username", userName); 
            jsonObject.put("email", "[email protected]"); 
            String msgString = jsonObject.toJSONString(); 
        jmsMessagingTemplate.convertAndSend(queue,msgString); 
        System.out.println("点对点通讯，msg"+msgString); 
    } 
}

package com.toov5.Producer; 
 
import javax.jms.Queue; 
 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.jms.core.JmsMessagingTemplate; 
import org.springframework.scheduling.annotation.Scheduled; 
import org.springframework.stereotype.Component; 
 
import com.alibaba.fastjson.JSONObject; 
 
@Component 
public class P2PProducer { 
    @Autowired 
    private JmsMessagingTemplate jmsMessagingTemplate; 
    //把队列注入进来  
    @Autowired  //此注解默认是以类型找  在配置文件中 已经注入的  @Bean  
    private Queue queue; 
     
    //每隔5s时间向队列发送消息 
    @Scheduled(fixedDelay=5000)  //每间隔2s向队列发送消息 
    public void send() { 
        String userName = System.currentTimeMillis()+" "; 
            JSONObject jsonObject  = new JSONObject(); 
            jsonObject.put("username", userName); 
            jsonObject.put("email", "[email protected]"); 
            String msgString = jsonObject.toJSONString(); 
             jmsMessagingTemplate.convertAndSend(queue,msgString); 
        System.out.println("点对点通讯，msg"+msgString); 
    } 
}

package com.toov5.config; 
 
import javax.jms.Queue; 
 
import org.apache.activemq.command.ActiveMQQueue; 
import org.springframework.beans.factory.annotation.Value; 
import org.springframework.context.annotation.Bean; 
import org.springframework.stereotype.Component; 
 
@Component 
public class ConfigQueue { 
   @Value("${my_queue}") 
   private String myQueue; 
     
    //首先将队列注入到SpringBoot容器中去 
    @Bean 
    public Queue queue() { 
        return new ActiveMQQueue(myQueue);  
    }  
     
}

package com.toov5; 
 
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.SpringBootApplication; 
import org.springframework.scheduling.annotation.EnableScheduling; 
 
@SpringBootApplication 
@EnableScheduling  //开启定时任务 
public class AppProducer { 
   public static void main(String[] args) { 
    SpringApplication.run(AppProducer.class, args); 
} 
}

spring: 
  activemq: 
    broker-url: tcp://192.168.91.6:61616 
    user: admin 
    password: admin 
my_queue: springboot-queue-toov5 
server: 
  port: 8081

package com.toov5.activemqConsumer; 
 
import org.apache.commons.lang3.StringUtils; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.annotation.Value; 
import org.springframework.jms.annotation.JmsListener; 
import org.springframework.mail.SimpleMailMessage; 
import org.springframework.mail.javamail.JavaMailSender; 
import org.springframework.stereotype.Component; 
 
import com.alibaba.fastjson.JSONObject; 
 
@Component 
public class P2PConsumer { 
    @Autowired 
    private JavaMailSender javaMailSender; 
    @Value("${spring.mail.username}") 
    private String toEmail; 
 
    @JmsListener(destination = "${my_queue}") // 用这个注解去监听 监听的队列 
    public void receiver(String msg) throws Exception { 
        if (StringUtils.isEmpty(msg)) { 
            return; 
        } 
        // 解析json 
        JSONObject parseObject  =  JSONObject.parseObject(msg);  //转成对象 
        String userName = parseObject.getString("username"); 
        String email = parseObject.getString("email"); 
        sendSimpleMail(email, userName); 
        System.out.println("消费者成功获取到生产者的消息，msg" + msg); 
    } 
 
    public void sendSimpleMail(String email, String userName) throws Exception { 
        SimpleMailMessage message = new SimpleMailMessage(); 
        // 邮件的来源 自己发自己 
        message.setFrom(email); 
        // 发送给谁 
        message.setTo(toEmail); 
        // 邮件标题 
        message.setSubject("toov5博客园提醒"); 
        // 邮件内容 
        message.setText("hello:" + userName + "我们成为好朋友!"); 
        // 发送邮件 
        javaMailSender.send(message); 
        System.out.println("邮件发送完成," + JSONObject.toJSONString(message)); 
    } 
 
}

package com.toov5.activemqConsumer; 
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.SpringBootApplication; 
 
@SpringBootApplication 
public class AppConsumer { 
 
    public static void main(String[] args) { 
        SpringApplication.run(AppConsumer.class, args); 
    } 
     
}

spring: 
  activemq: 
    broker-url: tcp://192.168.91.6:61616 
    user: admin 
    password: admin 
  mail: 
  ##163邮件服务 
    host: smtp.163.com 
    ##发送邮件账号 
    username: acmchangyuan@163.com 
    ##授权码 
    password: yugongv5 
    enable:  true 
    smtp: 
      auth: true 
    starttls: 
      enable: true 
      required: true 
my_queue: springboot-queue-toov5 
server: 
  port: 8080