云南网站设计模板/百度搜索优化软件

JMS（JAVA Message Service,java消息服务）API是一个消息服务的标准或者说是规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。
消息模型
即“点对点”和“发布订阅”

Point-to-Point(P2P)
Publish/Subscribe(Pub/Sub)

Point-to-Point(P2P)
Publish/Subscribe(Pub/Sub)

1. quickstart

例子地址
pom.xml依赖

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

application.properties

spring.activemq.broker-url=tcp://123.56.78.70:61616
spring.activemq.user=admin  
spring.activemq.password=admin  
spring.activemq.in-memory=true  
spring.activemq.pool.enabled=false

producer

/*** 源代码地址 https://github.com/spring-projects/spring-boot/tree/master/spring-boot-samples/spring-boot-sample-activemq* @date 2017年10月19日 下午5:19:24*/
@Component
public class Producer implements CommandLineRunner {@Beanpublic Queue queue() {return new ActiveMQQueue("sample.queue");}@Autowiredprivate JmsMessagingTemplate jmsMessagingTemplate;@Autowiredprivate Queue queue;@Overridepublic void run(String... args) throws Exception {for (int i = 0; i < 10; i++) {send("hullo boot activemq" + i);}System.out.println("Message was sent to the Queue");}public void send(String msg) {this.jmsMessagingTemplate.convertAndSend(this.queue, msg);}
}

@Component
public class Consumer {@JmsListener(destination = "sample.queue")public void receiveQueue(String text) {LogCore.BASE.info("收到的信息为{}", text);}
}

2. Spring官方例子

地址http://spring.io/guides/gs/messaging-jms/
Mail.java

public class Email {private String to;private String body;public Email() {}public Email(String to, String body) {this.to = to;this.body = body;}public String getTo() {return to;}public void setTo(String to) {this.to = to;}public String getBody() {return body;}public void setBody(String body) {this.body = body;}@Overridepublic String toString() {return String.format("Email{to=%s, body=%s}", getTo(), getBody());}
}

Receiver.java

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
import com.sonic.activemq.LogCore;
@Component
public class Receiver {@JmsListener(destination = "mailbox", containerFactory = "myFactory")public void receiveMessage(Email email) {System.out.println("Received <" + email + ">");LogCore.BASE.info("rsv msg:{}", email);}
}

JMSTest.java

@Configuration
public class JMSTest implements CommandLineRunner {@Beanpublic JmsListenerContainerFactory<?> myFactory(ConnectionFactory connectionFactory,DefaultJmsListenerContainerFactoryConfigurer configurer) {DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();// This provides all boot's default to this factory, including the message converterconfigurer.configure(factory, connectionFactory);// You could still override some of Boot's default if necessary.return factory;}@Bean // Serialize message content to json using TextMessagepublic MessageConverter jacksonJmsMessageConverter() {MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();converter.setTargetType(MessageType.TEXT);converter.setTypeIdPropertyName("_type");return converter;}@AutowiredJmsTemplate jmsTemplate;@Overridepublic void run(String... args) throws Exception {System.out.println("Sending an email message.");jmsTemplate.convertAndSend("mailbox", new Email("info@example.com", "Hello"));}
}

上面两个例子pom.xml和application.properties一样
但是要分开调试