正文

springcloud分布式事务实战准备数据库和创建第一个微服务(代码片段)

author  author  2022-11-23  202

关键词：

1)数据库准备
在数据库中mysql 分别创建2个数据库forum1和forum2
forum1 下创建表block
forum2下创建表Theme
sql代码如下：
1 数据库1Forum1:
CREATE DATABASE IF NOT EXISTS forum1;
USE forum1;
DROP TABLE IF EXISTS block;
CREATE TABLE block (
id int(11) NOT NULL AUTO_INCREMENT,
bname varchar(45) DEFAULT NULL,
bDescription varchar(45) DEFAULT NULL COMMENT ‘板块描述 ‘,
PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8 COMMENT=‘板块‘;

LOCK TABLES block WRITE;
INSERT INTO block VALUES (1,‘java‘,‘讨论java‘),(2,‘C++‘,‘讨论c++方面问题‘);
UNLOCK TABLES;

2 数据库forum2
CREATE DATABASE IF NOT EXISTS forum2 ;
USE forum2;

DROP TABLE IF EXISTS theme;
CREATE TABLE theme (
id int(11) NOT NULL AUTO_INCREMENT,
tName varchar(50) DEFAULT NULL COMMENT ‘主题名‘,
tDescription varchar(200) DEFAULT NULL COMMENT ‘主题描述‘,
blockid int(11) DEFAULT NULL COMMENT ‘区id‘,
PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8 COMMENT=‘主题‘;

LOCK TABLES theme WRITE;
INSERT INTO theme VALUES (1,‘java基础‘,‘java 基础‘,1),(2,‘javaWeb‘,‘java web‘,1);
UNLOCK TABLES;
2）编写第一个微服务BlockMicroService
（1）创建工程
技术分享图片

（2）添加 jar pom.xml
添加:springboot 父， mysql连接，(mybatis， spring-mybatis springboot ,阿里连接池) ,
服务中心客户端。

<groupId>com.jh</groupId>
<artifactId>BlockMicroService</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>BlockMicroService</name>
<url>http://maven.apache.org</url>
<!-- 1 spring boot parent -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.3.RELEASE</version>
    <relativePath />
</parent>

<!--1 属性 -->
<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.7</java.version>
    <maven.compile.source>1.7</maven.compile.source>
    <maven.compile.target>1.7</maven.compile.target>
    <spring-cloud.version>Dalston.SR1</spring-cloud.version>
    <lcn.last.version>4.1.0</lcn.last.version>
</properties>

<dependencies>
    <!--2 mysql -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.43</version>
    </dependency>

    <!-- 3 包括mybatis,mybatis-spring,spring boot,spring 等 -->
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.1.1</version>
    </dependency>

    <!--4  注册中心 -->

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

    <!-- 5 连接池 -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.0.19</version>
    </dependency>
    </dependencies>

<!-- spring cloud 依赖版本 -->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Dalston.SR3</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

</project>
（3）编写配置文件Application.properties

配置发布服务名，端口；配置中心地址；连接mysql 参数
#1 register server
#服务名
spring.application.name =blockMicroService
#服务端口
server.port =8020
#注册中心地址
eureka.client.service-url.defaultZone=http://127.0.0.1:8001/eureka

spring.datasource.driver-class-name =com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/forum1?useUnicode=true&characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false
spring.datasource.username= root
spring.datasource.password=
spring.datasource.initialize =true
init-db= true
logging.level.com.codingapi=debug
（4）编写实体，dao和映射。
实体：
public class Block

private  int  id;
private  String bname;
private  String bDescription;

get set …

Dao 和映射
package com.jh.dao;

@Mapper
public interface BlockDao

/**
 * 查询
 * 
 * @return
 */
@Select(value = "select *  from block")
public List<Block> getBlockList();

/**
 * 插入
 * 
 * @param bname
 * @param bDescription
 * @return
 */

@Insert(value = "insert  into block(bname,bDescription)" + " values(#bname,#bDescription)")

public int saveBlock(@Param("bname") String bname, @Param("bDescription") String bDescription);

（5）编写服务层

服务接口

public interface BlockService

List<Block> getBlockList();

int saveBlock(String bname, String bDescription);

服务实现：

@Service
public class BlockServiceImpl implements BlockService br/>@Autowired
private BlockDao blockDao;

@Override
public List<Block> getBlockList()
return blockDao.getBlockList();br/>
*/
@Override
public int saveBlock(String bName, String bDescription)

int rs1 = blockDao.saveBlock("jwg1", "111");// 保存1
return rs1;

（6）编写控制层

package com.jh.controller;br/>@RestController
public class BlockController
/ private final Logger logger = Logger.getLogger(getClass()); /

@Autowired
private BlockService blockService;// 区块服务，第一个服务

// 1接受请求
@RequestMapping(value = "/getBlockList", method = RequestMethod.GET)
public  List<Block> getBlockList() 
    List<Block>  blockList   = blockService.getBlockList();
    return   blockList;

// 2调用其他服务
@RequestMapping(value = "/saveBlock", method = RequestMethod.GET)
public String  saveBlock() 
    //调用服务
    Integer  result=blockService.saveBlock("cc", "cc");
    return  ;

（7）编写主程序
开启springboot应用程序，注册中心客户端，mybatis扫描和定义一个数据源
package com.jh;

import javax.sql.DataSource;
@SpringBootApplication //spring boot应用程序
@EnableEurekaClient //服务中心客户端
@MapperScan("com.jh.dao")//mybatis 扫描
public class BlockMicroService
public static void main(String[] args)

    SpringApplication.run(BlockMicroService.class, args);


//1环境
@Autowired
private Environment env;

@Bean
public DataSource dataSource() 
    DruidDataSource dataSource = new DruidDataSource();

    dataSource.setUrl(env.getProperty("spring.datasource.url"));
    dataSource.setUsername(env.getProperty("spring.datasource.username"));//用户名
    dataSource.setPassword(env.getProperty("spring.datasource.password"));//密码
    dataSource.setInitialSize(10);
    dataSource.setMaxActive(50);
    dataSource.setMinIdle(1);
    dataSource.setMaxWait(60000);
    dataSource.setValidationQuery("SELECT 1");
    dataSource.setTestOnBorrow(false);
    dataSource.setTestWhileIdle(true);
    dataSource.setPoolPreparedStatements(false);

    return dataSource;

（8）测试
启动注册中心，启动微服务
然后启动浏览器

springcloud分布式事务实战案例需求及实现步骤

...来说明如何使用分布式事务案例需求：创建2个基于springCloud的微服务，分别访问不同的数据库；然后创建一个整合服务，调用微服务实现数据的保存到2个不同的数据库，要求采用分布式事务，要么都成功，要么都失败。案... 查看详情

springcloud分布式事务实战改造thememicroservice支持分布式事务

（1）添加jar<dependency><groupId>com.codingapi</groupId><artifactId>transaction-springcloud</artifactId><version>${lcn.last.version}</v 查看详情

springcloud分布式事务实战改造合服务blockmicroservice支持分布式事务

在BlockMicroService工程中加入（1）加入jar<dependency><groupId>com.codingapi</groupId><artifactId>transaction-springcloud</artifactId><version>${ 查看详情

springcloud分布式事务实战分布式事务综合大测试（全，共10篇）

启动注册中心，启动redis,启动事务管理器启动mysql启动微服务1，启动微服务2（1）正常事务测试：不抛出异常，两边都插入1设计没有故障整合服务@TxTransaction(isStart=true)//关键4@Overridebr/>@TransactionalpublicintsaveBlockTheme(Blockblock,Themethem... 查看详情

springcloud分布式事务实战分布式事务处理器的下载，编译和运行

（1）下载分布式事务处理器工程源码https://github.com/codingapi/tx-lcn/（2）导入eclipse（3）修改配置文件填写分布式事务服务器地址，redis地址，注册中心地址#服务端口server.port=7000#tx-manager不得修改spring.application.name=tx-managerspring.mvc.st... 查看详情

springcloud分布式事务实战分布式事务处理器的编译和运行之redis安装

一、分布式事务处理器的编译和运行1)Redis的安装和启动(1)下载redis解压缩(2)启动和测试redis1进入redis目录2双击redis-server.exe程序即可启动3启动客户端测试双击redis-cli.exe输入查看详情

springcloud分布式事务实战编写第二个微服务(代码片段)

（1）创建工程（2）添加jarpom.xml添加:springboot父，mysql连接，(mybatis，spring-mybatisspringboot,阿里连接池),服务中心客户端。<projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSc 查看详情

springcloud分布式事务实战在微服务1中创建整合函数，调用微服务2

（1）添加jarpom.xml<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-feign</artifactId></dependency>（2）在主程序中添加注解@EnableFeignClien 查看详情

微服务框架springcloud之使用事件和消息队列实现分布式事务

不同于单一架构应用(Monolith),分布式环境下,进行事务操作将变得困难,因为分布式环境通常会有多个数据源,只用本地数据库事务难以保证多个数据源数据的一致性.这种情况下,可以使用两阶段或者三阶段提交协议来完成分布式事... 查看详情

分布式事务「2020年」必学，升职加薪你准备好了吗？

你是否学习了微服务架构SpringCloud、Dubbo，但是分布式事务却没有了解过？你是否尝试学习了分布式的概念，但是学习完却还不知所以然，一头雾水？你是否尝试使用了TXLCN、Fescar/Seata，但是却不知道它们的原理？?&n... 查看详情

springcloud（12）—分布式事务（seata）(代码片段)

SpringCloud（12）—分布式事务（Seata）一事务基础1.事务的ACID原则2.分布式事务问题在分布式系统下，一个业务跨越多个服务或数据源，每一个服务都是一个事务。要保证所有分支事务的最终状态一致，... 查看详情

springcloud整合alibaba和seata实现高性能的微服务分布式事务

SpringCloud是一个非常流行的微服务框架，它提供了丰富的组件和工具来简化分布式系统的开发。而Alibaba中间件则提供了多种优秀的分布式解决方案，如Nacos、Dubbo、RocketMQ等，而Seata作为阿里巴巴开源的一款分布式事务解决方案，... 查看详情

86springcloud解决分布式事务

参考技术A1，分布式事务产生的背景；分情况而定。1，在单体项目中，多个不同的业务逻辑都是在同一个数据源中心实现事务管理，是不存在分布式事务的问题。因为在同一个数据源的情况下都是采用事务管理器，相当于每个事... 查看详情

90springcloud解决分布式事务--lcn解决分布式事务

参考技术A1，分布式事务产生的背景。分情况而定1，在单体的项目中，多个不同的业务逻辑都是在同一个数据源中实现事务管理，是不存在分布式事务的问题，因为同一个数据源的情况都是采用事务管理器，相当于每个事务管理... 查看详情

springcloud分布式事务管理

SpringCloud分布式事务管理在微服务如火如荼的情况下，越来越多的项目开始尝试改造成微服务架构，微服务即带来了项目开发的方便性，又提高了运维难度以及网络不可靠的概率. SpringCloud分布式事务管理单体式架构微服务架... 查看详情

springcloudalibaba微服务组件seata分布式事务

...eataserver的配置到nacos3）启动SeataServer2.Seata如何整合到SpringCloud微服务2.1导入依赖2.2微服务对应数据库中添加undo_log表2.3微服务需要使用seataDataSourceProxy代理自己的数据源查看详情

使用kafka消息队列解决分布式事务

微服务框架SpringCloud介绍Part1:使用事件和消息队列实现分布式事务本文转自：http://skaka.me/blog/2016/04/21/springcloud1/不同于单一架构应用(Monolith),分布式环境下,进行事务操作将变得困难,因为分布式环境通常会有多个数据源,只用本地... 查看详情

正文