15《Spring Boot 入门教程》多数据源与分布式事务

一个项目中使用多个数据源的需求，我们在日常工作中时常会遇到。

以商城系统为例，有一个 MySQL 的数据库负责存储交易数据。公司还有一套 ERP 企业信息化管理系统，要求订单信息同步录入 ERP 数据库，便于公司统一管理，而该 ERP 系统采用的数据库为 SQL Server 。

此时，就可以在 Spring Boot 项目中配置多个数据源。另外，使用多数据源后，需要采用分布式事务来保持数据的完整性。

本小节我们使用 Spring Boot 开发一个商城系统的订单生成功能，订单信息同时进入 MySQL 与 SQL Server 数据库。

首先创建 MySQL 数据库 shop ，并新建订单表 order ，表结构如下：

order 表结构

然后创建 SQL Server 数据库 erpshop ，并新建订单表 erp_order ，表结构如下。注意 id 是自增长的唯一标识，out_id 是对应订单在 MySQL 数据库中的唯一标识，以便在两个库中比对订单。

erp_order 结构

接下来，我们开始实现 Spring Boot 后端项目，数据持久层采用 MyBatis 框架，同时访问两个数据源。

Spring Boot 版本选择 225 ，Group 为 comimooc ， Artifact 为 spring-boot-multidb，生成项目后导入 Eclipse 开发环境。

我们引入热部署依赖、 Web 依赖、数据库访问相关依赖及测试相关依赖，具体如下：

实例：

由于我们要同时访问两个数据库，所以需要在配置文件中添加两个数据源的配置信息。注意配置多数据源时， url 配置需要使用 springdatasourcedb1jdbc-url=xxx 的形式。

实例：

多个数据源的情况下， 我们需要通过配置类，将数据源注册为组件放入 Spring 容器中。

实例：

通过这个配置类， Spring 容器中就有两个数据源组件，这两个组件分别采用 springdatasourcedb1 和 springdatasourcedb2 开头的配置信息。所以通过这两个组件，就能分别 *** 作 MySQL 数据源 1 和 SQL Sever 数据源 2 。

多数据源情况下， MyBatis 中的关键组件 SqlSessionFactory 和 SqlSessionTemplate 也需要单独配置，我们需要为两个数据源分别配置一套组件。

实例：

通过上面的配置类， comimoocspringbootmultidbmapper1 包中的 DAO 数据访问接口会自动调用 sqlSessionTemplate1 组件实现具体数据库 *** 作，而 sqlSessionTemplate1 *** 作的数据源已经通过配置类设置为 db1 。同时， DAO 数据访问接口对应的映射文件已经指定到 classpath:mapper1/ 目录去寻找。这样数据源 – DAO 数据访问接口 – 映射文件三者的对应关系就建立起来了。

数据源 2 的配置方法是一样的， comimoocspringbootmultidbmapper2 包中的 DAO 数据访问接口会自动调用 sqlSessionTemplate2 组件，其 *** 作的数据源即为 db2 ，其对应的映射文件指定到 classpath:mapper2/ 目录去寻找。

实例：

数据访问接口的位置已经在配置类指定，首先在 comimoocspringbootmultidbmapper1 创建 OrderDao ， *** 作的是数据源 1 中的 order 表。

实例：

然后在 comimoocspringbootmultidbmapper2 创建 ErpOrderDao ， *** 作的是数据源 2 中的 erporder 表。

实例：

这两个接口中使用的数据对象比较简单，代码如下：

实例：

分别针对 OrderDao 、 ErpOrderDao 编写对应的映射文件，然后按照配置类指定的位置，两个文件分别放到 resources/mapper1 和 resources/mapper2 目录下。

实例：

实例：

数据 *** 作接口与对应的映射文件均已编写完毕，现在可以通过测试类进行多数据源测试了，我们在测试类中同时向两个库插入记录。

实例：

运行测试方法后，两个数据库表中均新增数据成功，这样我们就成功的使用 Spring Boot 同时 *** 作了两个数据源。

采用多数据源之后，事务的实现方式也随之发生变化。当某个数据源 *** 作出现异常时，该数据源和其他数据源的事务都需要回滚。这种涉及多个数据源的事务，称为分布式事务，接来下我们就来具体实现一下。

在 pomxml 引入 Atomikos 事务管理器相关的依赖项， Atomikos 是一个开源的事务管理器，支持分布式事务。

实例：

需要将默认的数据源更换为支持分布式事务的数据源， MySQL 对应的数据源为 MysqlXADataSource ， SQL Server 对应的数据源为 SQLServerXADataSource 。

实例：

继续修改 DataSourceConfig 类，在其中配置分布式事务管理器组件。当项目中使用事务时，会通过配置的分布式事务管理器管理分布式事务 *** 作。

实例：

在测试方法上添加 @Transactional 开启事务，然后在两个数据源 *** 作中间模拟抛出异常。

实例：

此时运行测试类，可以发现数据源 1 的事务已回滚，验证成功！

在开发 Spring Boot 项目时，如果默认配置满足不了我们的需求，可以通过手工配置组件实现我们需要的功能。这些组件可能是各个公司提供的，我们根据相应文档，为其配置各个属性即可。

spring-boot适合开发web应用的静态资源访问在我们开发Web应用的时候，需要引用大量的js、css、等静态资源。默认配置SpringBoot默认提供静态资源目录位置需置于classpath下，目录名需符合如下规则：/static/public/resources/META-INF/resources举例：我们可以在src/main/resources/目录下创建static，在该位置放置一个文件。启动程序后，尝试访问页面的时候，要如何实现呢？模板引擎在动态HTML实现上SpringBoot依然可以完美胜任，并且提供了多种模板引擎的默认配置支持，所以在推荐的模板引擎下，我们可以很快的上手开发动态网站。SpringBoot提供了默认配置的模板引擎主要有以下几种：ThymeleafFreeMarkerVelocityGroovyMustacheSpringBoot建议使用这些模板引擎，避免使用JSP，若一定要使用JSP将无法实现SpringBoot的多种特性，具体可见后文：支持JSP的配置当你使用上述模板引擎中的任何一个，它们默认的模板配置路径为：src/main/resources/templates。当然也可以修改这个路径，具体如何修改，可在后续各模板引擎的配置属性中查询并修改。ThymeleafThymeleaf是一个XML/XHTML/HTML5模板引擎，可用于Web与非Web环境中的应用开发。它是一个开源的Java库，基于ApacheLicense20许可，由DanielFernández创建，该作者还是Java加密库Jasypt的作者。Thymeleaf提供了一个用于整合SpringMVC的可选模块，在应用开发中，你可以使用Thymeleaf来完全代替JSP或其他模板引擎，如Velocity、FreeMarker等。Thymeleaf的主要目标在于提供一种可被浏览器正确显示的、格式良好的模板创建方式，因此也可以用作静态建模。你可以使用它创建经过验证的XML与HTML模板。相对于编写逻辑或代码，开发者只需将标签属性添加到模板中即可。接下来，这些标签属性就会在DOM（文档对象模型）上执行预先制定好的逻辑。

spring和spring boot区别如下：

1、Spring框架：

就像一个家族有众多衍生产品例如boot、security、jpa等等但他们的基础都是Spring的ioc和aopioc提供了依赖注入的容器aop解决了面向横切面的编程然后在此两者的基础上实现了其他延伸产品的高级功能。

2、spring boot：

是基于Servlet的一个MVC框架主要解决WEB开发的问题因为Spring的配置非常复杂各种XML、JavaConfig、hin处理起来比较繁琐于是为了简化开发者的使用，从而创造性地推出了Springboot，约定优于配置简化了spring的配置流程。

spring短语搭配：

Leaf Spring 钢板d簧 ; 叶片d簧 ; [机] 板d簧 ; [机] 片簧

Early Spring 早春图 ; 早春 ; 早春二月 ; 烟花三月

Spring rolls 春卷 ; 脆皮春卷 ; 第三道春卷 ; 秋卷

Silent Spring 寂静的春天 ; 沉寂的春天 ; 无声的春天 ; 沉静的春天

Air Spring [机] 空气d簧 ; 气垫 ; 空翻 ; 春秋航空

在学习springboot过程中，发现一个可以二开的开源项目，是一个Java EE 企业级快速开发平台，多项目依赖，模块式开发。

官网地址：>

[TOC]

Spring Boot作为简化Spring开发的框架，已经为我们集成了ActiveMQ和RabbitMQ。只需在Spring Boot配置几个MQ的连接方式即可开箱即用。大大简化了开发配置过程。
Spring的JavaConfig相比传统的XML的配置方式使得配置更加的可靠和方便。
本文将会说明如何用JavaConfig的方式将Spring与IBM WebSphere MQ（以下简称IBM MQ）集成配置，也可以作为其他MQ的配置参考。

17年后官方maven仓库以有相关依赖

IBM MQ相关的连接依赖包为 comibmmqallclientjar ，该包不存在于公共Maven仓库，所以我们需要找到该依赖包并手动安装到我们本机的Maven仓库中。
该依赖包位于 [IBM MQ 安装路径]\java\lib 下，Windows下的默认安装路径为 C:\Program Files\IBM\WebSphere MQ\ ，Linux下的默认安装路径为 /opt/mqm/ 。可以将该包复制到开发机上。
通过以下命令安装该包到本地仓库

在Idea中可以按四次Shift键调出全局搜索框，键入Execute Maven Goal，等待搜索结果后按回车，即可执行Maven命令， 在此执行命令时不需要键入命令开头的 mvn 。

编辑项目pomxml文件，添加以下三个依赖，分别为

配置Spring Boot配置文件，applicationyml，此处用的是yaml格式配置文件，applicationproperties的配置方法可以参考Spring Boot的说明。

建立 JmsConfig 类，添加注解 @Configuration ，并将以上属性注入到此类。

在JmsConfig类添加以下方法。

不配置该类则每次与MQ交互都需要重新创建连接，大幅降低速度。

不使用事务可以跳过该步骤。如需使用事务，可添加注解 @EnableTransactionManagement 到程序入口类中，事务的具体用法可参考Spring Trasaction。

JmsOperations为JmsTemplate的实现接口。

重要：不设置setReceiveTimeout时，当队列为空，从队列中取出消息的方法将会一直挂起直到队列内有消息

可直接使用jmsOperations的convertAndSend(String, Object)方法，第一个参数为队列名称，第二个参数为需发送的对象。

重要：发送的对象需实现序列化接口

可直接使用jmsOperations的receiveAndConvert(String)方法，第一个参数为队列名称。

如需使用事务，只需在方法添加注解 @Transactional(value = "jmsTransactionManager") 即可。

有问题请留言

RSocket应用层协议支持 Reactive Streams语义， 例如：用RSocket作为>