SpringBoot实战(十一)之与JMS简单通信

什么是JMS？

引用百度百科上的说明:

JMS即

Java消息服务（Java Message Service）应用程序接口，是一个 Java平台中关于面向消息中间件（MOM）的 API ，用于在两个应用程序之间，或分布式系统

中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。

JMS是一种与厂商无关的 API，用来访问消息收发系统消息，它类似于

(Java Database Connectivity)。这里，JDBC 是可以用来访问许多不同关系数据库的 API，而 JMS 则提供同样与厂商无关的访问方法，以访问消息收发服务。许多厂商都支持 JMS，包括 IBM 的 MQSeries、BEA的 Weblogic JMS service和 Progress 的 SonicMQ。 JMS 使您能够通过消息收发服务（有时称为消息中介程序或路由器）从一个 JMS 客户机向另一个 JMS客户机发送消息。消息是 JMS 中的一种类型对象，由两部分组成：报头和消息主体。报头由路由信息以及有关该消息的元数据组成。消息主体则携带着应用程序的数据或有效负载。根据有效负载的类型来划分，可以将消息分为几种类型，它们分别携带：简单文本(TextMessage)、可序列化的对象 (ObjectMessage)、属性集合 (MapMessage)、字节流 (BytesMessage)、原始值流 (StreamMessage)，还有无有效负载的消息 (Message)。

下面进入SpringBoot简单使用JMS示例:

一、导入依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.springframework</groupId>
    <artifactId>gs-messaging-jms</artifactId>
    <version>0.1.0</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.8.RELEASE</version>
    </parent>

    <properties>
        <java.version>1.8</java.version>
    </properties>

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

        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

二、编写消息接收器

package hello;

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;
    }

    @Override
    public String toString() {
        return String.format("Email{to=%s, body=%s}", getTo(), getBody());
    }

}

三、定义消息接收者

package hello;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class Receiver {

    @JmsListener(destination = "mailbox", containerFactory = "myFactory")
    public void receiveMessage(Email email) {
        System.out.println("Received <" + email + ">");
    }

}

Receiver

也被称为消息驱动的POJO。正如您在上面的代码中所看到的，不需要实现任何特定的接口或方法具有任何特定的名称。此外，该方法可以具有

非常灵活的签名

。请特别注意，此类在JMS API上没有导入。

四、使用Spring发送和接收JMS消息

package hello;

import javax.jms.ConnectionFactory;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
import org.springframework.jms.support.converter.MessageConverter;
import org.springframework.jms.support.converter.MessageType;

@SpringBootApplication
@EnableJms
public class Application {

    @Bean
    public JmsListenerContainerFactory<?> myFactory(ConnectionFactory connectionFactory,
                                                    DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        // This provides all boot's default to this factory, including the message converter
        configurer.configure(factory, connectionFactory);
        // You could still override some of Boot's default if necessary.
        return factory;
    }

    @Bean // Serialize message content to json using TextMessage
    public MessageConverter jacksonJmsMessageConverter() {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setTargetType(MessageType.TEXT);
        converter.setTypeIdPropertyName("_type");
        return converter;
    }

    public static void main(String[] args) {
        // Launch the application
        ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);

        JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class);

        // Send a message with a POJO - the template reuse the message converter
        System.out.println("Sending an email message.");
        jmsTemplate.convertAndSend("mailbox", new Email("[email protected]", "Hello"));
    }

}

@Bean注解，主要作用是控制反转(IOC），同

</bean>

举例说明:

例如以Message为例:

@Bean
public String message() {
    return new String("hello");
}

它等价于

<bean id="message" class="java.lang.String">
    <constructor-arg index="0" value="hello"/>
</bean>

通常情况下，有三种配置Bean的方式:

如图所示

关于Bean注解三种配置法，深入介绍可以参考该博文:https://blog.csdn.net/icarus_wang/article/details/51649635

@EnableJms

触发发现带注释的方法

@JmsListener

，在封面下创建消息监听器容器。

为清楚起见，我们还定义了一个在接收器注释中

myFactory

引用的bean

JmsListener

。因为我们使用

DefaultJmsListenerContainerFactoryConfigurer

Spring Boot提供的基础结构，所以

JmsMessageListenerContainer

它与默认情况下引导创建的基础结构相同。

默认

MessageConverter

是能够转换只有基本类型（例如

String

，

Map

Serializable

）我们

Email

是不是

Serializable

故意的。我们想要使用Jackson并以文本格式将内容序列化为json（即作为a

TextMessage

）。Spring Boot将检测a的存在，

MessageConverter

并将其与默认值

JmsTemplate

和任何

JmsListenerContainerFactory

创建者相关联

DefaultJmsListenerContainerFactoryConfigurer

。

JmsTemplate

使消息发送到JMS目的地变得非常简单。在

main

runner方法中，启动后，您可以使用

jmsTemplate

发送

Email

POJO。因为我们的自定义

MessageConverter

已自动关联到它，所以只会生成一个json文档

TextMessage

你没看到的两个bean是

JmsTemplate

和

ConnectionFactory

。这些是由Spring Boot自动创建的。在这种情况下，ActiveMQ代理运行嵌入式。

注意:

Spring

JmsTemplate

可以通过它的

receive

方法直接接收消息，但这只能同步工作，这意味着它会阻塞。这就是为什么我们建议您使用侦听器容器，例如

DefaultMessageListenerContainer

使用基于缓存的连接工厂，这样您就可以异步使用消息并以最大的连接效率。

最后运行结果如下图所示:

SpringBoot实战(十一)之与JMS简单通信

继续阅读

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的简单使用

neo4j之cypher使用文档

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

mybatis_入门程序Mybatis入门

vue-cli简介（中文翻译）

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

Ajax发送和获取json数据到Spring mvc 1.spring mvc后端2.web前段

Effective Java 8:通用程序设计

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method

JSONObject包导入异常 java.lang.NoClassDefFoundErrorweb项目的导入包的问题