Java--SpringBoot-30-简单使用ActiveMQ

<!--activemq--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId></dependency>

#####################activemq#####################spring.activemq.broker-url=tcp://127.0.0.1:61616

packagecom.xing.studyboot.message;
importjavax.jms.Destination;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.jms.core.JmsMessagingTemplate;
importorg.springframework.stereotype.Service;
/***  生产者* @author xing* @createTime*/@Service("producer")
publicclassProducer {
@AutowiredJmsMessagingTemplatejmsTemplate;
/*** 发送消息** @param destination 发送到的队列名* @param message     消息体*/publicvoidsendMessage(Stringdestination, Stringmessage) {
System.out.println("给队列【qqq】发送消息："+message);
jmsTemplate.convertAndSend(destination, message);
    }
}

packagecom.xing.studyboot.message;
importorg.springframework.jms.annotation.JmsListener;
importorg.springframework.stereotype.Component;
@ComponentpublicclassConsumer{
@JmsListener(destination="qqq")    //queue名publicvoidreceiveQueue(Stringtxt) {
System.out.println("监听到【qqq】队列的消息:"+txt);
  }
}

packagecom.xing.studyboot.rest.controller;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.web.bind.annotation.PathVariable;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;
importcom.xing.studyboot.message.Producer;
/***  消息测试服务* @author xing**/@RestController@RequestMapping("/msg")
publicclassMessageController {
@AutowiredprivateProducerproducer;
@RequestMapping("/sendMessage/{msg}")
publicStringtestEndpoint(@PathVariableStringmsg) {
producer.sendMessage("qqq", msg);
return"消息【  "+msg+" 】发送成功";
  }
}

http://127.0.0.1:8888/studySpringBoot/msg/sendMessage/发个消息