spring boot注釋

1.簡介

在以前的文章中，我們學(xué)習了如何使用Spring JMS配置項目。 如果查看有關(guān)使用Spring JMS進行消息傳遞的文章介紹 ，您會注意到它是使用XML配置的。 本文將利用Spring 4.1版本中引入的改進 ，并僅使用Java config配置JMS項目。

在這個示例中，我們還將看到使用Spring Boot配置項目是多么容易。

在開始之前，請注意，您可以像往常一樣查看下面示例中使用的項目的源代碼。

請參閱github上的示例項目 。

欄目：

介紹。

示例應(yīng)用程序。

設(shè)置項目。

一個使用JMS偵聽器的簡單示例。

使用@SendTo將響應(yīng)發(fā)送到另一個隊列。

結(jié)論。

2.示例應(yīng)用程序

該應(yīng)用程序使用客戶端服務(wù)將訂單發(fā)送到JMS隊列，在該隊列中將注冊JMS偵聽器并處理這些訂單。 收到后，偵聽器將通過Store服務(wù)存儲訂單：

我們將使用Order類創(chuàng)建訂單：

public class Order implements Serializable {private static final long serialVersionUID = -797586847427389162L;private final String id;public Order(String id) {this.id = id;}public String getId() {return id;} }

在繼續(xù)第一個示例之前，我們將首先探討如何構(gòu)建項目結(jié)構(gòu)。

3.設(shè)置項目

3.1配置pom.xml

首先要做的是將工件spring-boot-starter-parent定義為我們的父pom。

<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.2.3.RELEASE</version><relativePath/> <!-- lookup parent from repository --> </parent>

這個父級基本上設(shè)置了幾個Maven默認值，并為我們將要使用的主要依賴項提供了依賴項管理，例如Spring版本（4.1.6）。

重要的是要注意，此父pom定義了許多庫的版本，但未對我們的項目添加任何依賴關(guān)系。 因此，不必擔心會得到不使用的庫。

下一步是設(shè)置Spring Boot的基本依賴關(guān)系：

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

除了核心Spring庫之外，此依賴項還將帶來Spring Boot的自動配置功能。 這將允許框架嘗試根據(jù)您添加的依賴項自動設(shè)置配置。

最后，我們將添加Spring JMS依賴項和ActiveMQ消息代理，將整個pom.xml保留如下：

<groupId>xpadro.spring</groupId> <artifactId>jms-boot-javaconfig</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>JMS Spring Boot Javaconfig</name><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.2.3.RELEASE</version><relativePath/> <!-- lookup parent from repository --> </parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><start-class>xpadro.spring.jms.JmsJavaconfigApplication</start-class><java.version>1.8</java.version><amq.version>5.4.2</amq.version> </properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jms</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-core</artifactId><version>${amq.version}</version></dependency> </dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins> </build>

3.2使用Java Config進行Spring配置

配置類僅需要配置嵌入式消息代理。 其余的由Spring Boot自動配置：

@SpringBootApplication public class JmsJavaconfigApplication {private static final String JMS_BROKER_URL = "vm://embedded?broker.persistent=false,useShutdownHook=false";@Beanpublic ConnectionFactory connectionFactory() {return new ActiveMQConnectionFactory(JMS_BROKER_URL);}public static void main(String[] args) {SpringApplication.run(JmsJavaconfigApplication.class, args);} }

我們使用@SpringBootApplication而不是通常的@Configuration批注。 這個Spring Boot注釋也用@Configuration注釋。 此外，它還設(shè)置其他配置，例如Spring Boot自動配置：

@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) @Documented @Inherited @Configuration @EnableAutoConfiguration @ComponentScan public @interface SpringBootApplication {

現(xiàn)在都設(shè)置好了。 在下一節(jié)的示例中，我們將了解如何配置JMS偵聽器，因為它已配置了注釋。

4.使用JMS偵聽器的簡單示例

4.1將訂單發(fā)送到JMS隊列

ClientService類負責將新訂單發(fā)送到JMS隊列。 為了做到這一點，它使用一個JmsTemplate：

@Service public class ClientServiceImpl implements ClientService {private static final String SIMPLE_QUEUE = "simple.queue";private final JmsTemplate jmsTemplate;@Autowiredpublic ClientServiceImpl(JmsTemplate jmsTemplate) {this.jmsTemplate = jmsTemplate;}@Overridepublic void addOrder(Order order) {jmsTemplate.convertAndSend(SIMPLE_QUEUE, order);} }

在這里，我們使用JmsTemplate轉(zhuǎn)換Order實例并將其發(fā)送到JMS隊列。 如果您希望直接通過發(fā)送消息發(fā)送消息，則可以使用新的JmsMessagingTemplate 。 這是更好的選擇，因為它使用了更加標準化的Message類。

4.2接收發(fā)送到JMS隊列的訂單

將JMS偵聽器注冊到JMS偵聽器容器就像將@JmsListener批注添加到我們要使用的方法一樣簡單。 這將在幕后創(chuàng)建一個JMS偵聽器容器，該容器將接收發(fā)送到指定隊列的消息并將它們委派給我們的偵聽器類：

@Component public class SimpleListener {private final StoreService storeService;@Autowiredpublic SimpleListener(StoreService storeService) {this.storeService = storeService;}@JmsListener(destination = "simple.queue")public void receiveOrder(Order order) {storeService.registerOrder(order);} }

StoreService接收訂單并將其保存到已接收訂單的列表中：

@Service public class StoreServiceImpl implements StoreService {private final List<Order> receivedOrders = new ArrayList<>();@Overridepublic void registerOrder(Order order) {this.receivedOrders.add(order);}@Overridepublic Optional<Order> getReceivedOrder(String id) {return receivedOrders.stream().filter(o -> o.getId().equals(id)).findFirst();} }

4.3測試應(yīng)用程序

現(xiàn)在讓我們添加一個測試來檢查我們是否正確完成了所有操作：

@RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = JmsJavaconfigApplication.class) public class SimpleListenerTest {@Autowiredprivate ClientService clientService;@Autowiredprivate StoreService storeService;@Testpublic void sendSimpleMessage() {clientService.addOrder(new Order("order1"));Optional<Order> storedOrder = storeService.getReceivedOrder("order1");Assert.assertTrue(storedOrder.isPresent());Assert.assertEquals("order1", storedOrder.get().getId());} }

5.使用@SendTo將響應(yīng)發(fā)送到另一個隊列

Spring JMS的另一個附加功能是@SendTo批注。 此批注允許偵聽器將消息發(fā)送到另一個隊列。 例如，以下偵聽器從“ in.queue”接收命令，并在存儲該命令后將確認發(fā)送到“ out.queue”。

@JmsListener(destination = "in.queue") @SendTo("out.queue") public String receiveOrder(Order order) {storeService.registerOrder(order);return order.getId(); }

在那里，我們注冊了另一個偵聽器，它將處理此確認ID：

@JmsListener(destination = "out.queue") public void receiveOrder(String orderId) {registerService.registerOrderId(orderId); }

六，結(jié)論

有了注釋支持，現(xiàn)在可以更輕松地配置Spring JMS應(yīng)用程序，從而利用帶注釋的JMS偵聽器進行異步消息檢索。

翻譯自: https://www.javacodegeeks.com/2015/04/configure-a-spring-jms-application-with-spring-boot-and-annotation-support.html

spring boot注釋

總結(jié)

以上是生活随笔為你收集整理的spring boot注释_使用Spring Boot和注释支持配置Spring JMS应用程序的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。