黑马程序员技术交流社区

标题: 【上海校区】SpringBoot快速集成ActiveMq [打印本页]

---

作者: 阿莱    时间: 2019-10-17 16:22
标题: 【上海校区】SpringBoot快速集成ActiveMq

【上海校区】SpringBoot快速集成ActiveMq

一、什么是Spring Boot

Spring 诞生时是 Java 企业版（Java Enterprise Edition，JEE，也称 J2EE）的轻量级代替品。无需开发重量级的 Enterprise JavaBean（EJB），Spring 为企业级Java 开发提供了一种相对简单的方法，通过依赖注入和面向切面编程，用简单的Java 对象（Plain Old Java Object，POJO）实现了 EJB 的功能。

虽然 Spring 的组件代码是轻量级的，但它的配置却是重量级的。一开始，Spring 用 XML 配置，而且是很多 XML 配置。Spring 2.5 引入了基于注解的组件扫描，这消除了大量针对应用程序自身组件的显式 XML 配置。Spring 3.0 引入了基于 Java 的配置，这是一种类型安全的可重构配置方式，可以代替 XML。所有这些配置都代表了开发时的损耗。因为在思考 Spring 特性配置和解决业务问题之间需要进行思维切换，所以写配置挤占了写应用程序逻辑的时间。和所有框架一样，Spring 实用，但与此同时它要求的回报也不少。

        除此之外，项目的依赖管理也是件吃力不讨好的事情。决定项目里要用哪些库就已经够让人头痛的了，你还要知道这些库的哪个版本和其他库不会有冲突，这难题实在太棘手。并且，依赖管理也是一种损耗，添加依赖不是写应用程序代码。一旦选错了依赖的版本，随之而来的不兼容问题毫无疑问会是生产力杀手。
Spring Boot 让这一切成为了过去。
    Spring Boot 是 Spring 社区较新的一个项目。该项目的目的是帮助开发者更容易的创建基于 Spring 的应用程序和服务，让更多人的人更快的对 Spring 进行入门体验，为 Spring 生态系统提供了一种固定的、约定优于配置风格的框架。

Spring Boot 具有如下特性：
（1）为基于 Spring 的开发提供更快的入门体验
（2）开箱即用，没有代码生成，也无需 XML 配置。同时也可以修改默认值来满足特定的需求。
（3）提供了一些大型项目中常见的非功能性特性，如嵌入式服务器、安全、指标，健康检测、外部配置等。
（4）Spring Boot 并不是不对 Spring 功能上的增强，而是提供了一种快速使用 Spring 的方式。

二、项目搭建
1、项目依赖

[XML] 纯文本查看 复制代码

<properties>

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

    </properties>



    <parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.0.6.RELEASE</version>

    </parent>



    <dependencies>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>



        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-activemq</artifactId>

        </dependency>

    </dependencies>

2、启动类

[Java] 纯文本查看 复制代码

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;



@SpringBootApplication

public class Application {



    public static void main(String[] args) {



        SpringApplication.run(Application.class);

    }

}

3、消息生产者

[Java] 纯文本查看 复制代码

@RestController

public class QueueController {

    @Autowired

    private JmsMessagingTemplate jmsMessagingTemplate;



    @RequestMapping("/send")

    public void send(String text) {



        jmsMessagingTemplate.convertAndSend("msg", text);

    }

}

4、消息消费者

[Java] 纯文本查看 复制代码

import org.springframework.jms.annotation.JmsListener;

import org.springframework.stereotype.Component;



@Component

public class Consumer {

        @JmsListener(destination="msg")

        public void readMessage(String text){



                System.out.println("接收到消息："+text);

        }        

}

5、使用外部服务
在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址

[XML] 纯文本查看 复制代码

spring.activemq.broker-url=tcp://192.168.25.135:61616

三、发送Map信息
1、修改QueueController.java

[Java] 纯文本查看 复制代码

        @RequestMapping("/sendmap")

        public void sendMap(){

                Map map=new HashMap<>();

                map.put("mobile", "13900001111");

                map.put("content", "恭喜获得10元代金券");                

                jmsMessagingTemplate.convertAndSend("my_map",map);

        }

2、修改Consumer.java

[Java] 纯文本查看 复制代码

        @JmsListener(destination="my_map")

        public void readMap(Map map){

                System.out.println(map);                

        }

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2