练习 - 向 Azure 服务总线发送消息

5 分钟

在本单元，你将创建一个 Spring Boot 应用程序，以向 Azure 服务总线队列发送消息。在本地完成以下步骤。

创建 Spring Boot 项目

为了创建 Spring Boot 项目，我们将在以下命令行中使用 Spring Initializr：

curl https://start.spring.io/starter.tgz -d type=maven-project -d dependencies=web -d baseDir=spring-sender-application -d bootVersion=2.4.1.RELEASE -d javaVersion=1.8 | tar -xzvf -

将消息发送到服务总线队列

现在，让我们将一些消息发送到服务总线队列。

为服务总线 Spring Boot Starter 添加 Maven 依赖项

在 spring-sender-application 的 pom.xml 文件中，在依赖项下添加以下命令：

            <dependency>
                <groupId>com.microsoft.azure</groupId>
                <artifactId>azure-servicebus-jms-spring-boot-starter</artifactId>
                <version>2.3.3</version>
            </dependency>

添加配置参数

在 spring-sender-application\src\main\resources 文件夹中，编辑 application.properties 文件，添加以下参数：
```
spring.jms.servicebus.connection-string=<xxxxx>
spring.jms.servicebus.idle-timeout=20000
```
将 spring.jms.servicebus.connection-string 属性设置为前面保存的服务总线命名空间的连接字符串。

添加向服务总线发送消息的代码

接下来，我们将添加用于向服务总线队列发送消息的业务逻辑。

在 src/main/java/com/example/demo 目录中，创建一个具有以下内容的 SendController.java 文件：

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SendController {
    
    private static final String queue = "test-queue-jms";

    @Autowired
    private JmsTemplate jmsTemplate;

    @GetMapping("/messages")
    public String postMessage(@RequestParam String message) {
        jmsTemplate.send(queue, s -> s.createTextMessage(message));
        return message;
    }
}

在本地运行应用程序

切换回 pom.xml 文件所在的示例 spring-sender-application 文件夹的根，然后运行以下命令以启动 Spring Boot 应用程序。此步骤假定你已在 Windows 计算机上安装 mvn，并且它位于 PATH 中。
```
mvn spring-boot:run
```
应用程序启成后，你可选择以下链接来将消息发送到服务总线队列。
```
http://localhost:8080/messages?message=Hello
```
```
http://localhost:8080/messages?message=HelloAgain
```
```
http://localhost:8080/messages?message=HelloOnceAgain
```
可以更改消息查询参数中的字符串值，并向服务总线队列发送任何文本。

浏览器显示作为消息查询字符串参数传递的任何内容，这意味着服务总线正在接受该消息。