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

author author     2023-01-13     182

关键词:

(1)创建工程
技术分享图片

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

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">;
<modelVersion>4.0.0</modelVersion>

<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 =themeMicroService
#服务端口
server.port =8021
#注册中心地址
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/forum2?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 Theme
private Integer id;
private String tName;
private String tDescription;
get set

Dao 和映射br/>@Mapper
public interface ThemeDao

/**
 * 查询
 * 
 * @return
 */
@Select(value = "select *  from theme")
public List<Theme> getThemeList();

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

@Insert(value = "insert  into theme(tName,tDescription,blockId)" + " values(#tName,#tDescription,"
        + "#blockId)")
public int saveTheme(@Param("tName") String tName, @Param("tDescription") String tDescription,  @Param("blockId")  Integer blockId);


(5)编写服务层

服务接口

public interface ThemeService

List<Theme> getThemeList();
int saveTheme(String tName, String  tDescription , Integer blockId);


服务实现:
package com.jh.service.impl;

@Service
public class ThemeServiceImpl implements ThemeService
br/>@Autowired
private ThemeDao themeDao;

@Override
public List<Theme> getThemeList() 
    return themeDao.getThemeList();

@Override
public int saveTheme(String tName, String tDescription, Integer blockId) 
    // TODO Auto-generated method stub
    int rs1 = themeDao.saveTheme(tName, tDescription, blockId);// 保存1
    return rs1;

(6)编写控制层 br/>@RestController
public class ThemeController

@Autowired
private ThemeService themeService;// 块服务,第一个服务

// 1接受请求
@RequestMapping(value = "/getThemeList", method = RequestMethod.GET)
public List<Theme> getThemeList() 
    List<Theme> ThemeList = themeService.getThemeList();
    return ThemeList;


@RequestMapping(value = "/saveTheme", method = RequestMethod.GET)
public  int saveTheme() 
    Integer result = themeService.saveTheme("jwg2", "jwg2", 1); 
return   result 

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

@SpringBootApplication //spring boot应用程序br/>@EnableEurekaClient
@MapperScan("com.jh.dao")
public class ThemeMicroService
public static void main(String[] args)

    SpringApplication.run(ThemeMicroService.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<!--springCloud事务关键点1--><dependency><groupId>com.codingapi</groupId><artifactId>transaction-springcloud</artifactId><version>${lcn.last.version}</v 查看详情

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

在BlockMicroService工程中加入(1)加入jar<!--springCloud事务关键点1--><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

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

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

1)数据库准备在数据库中mysql分别创建2个数据库forum1和forum2forum1下创建表blockforum2下创建表Themesql代码如下:1数据库1Forum1:CREATEDATABASEIFNOTEXISTSforum1;USEforum1;DROPTABLEIFEXISTSblock;CREATETABLEblock(idint(11)NOTNULLAUTO_INCREMEN 查看详情

分布式事务处理方案,微服事务处理方案(代码片段)

微服事务处理方案(分布式事务处理方案)1.什么是事务由一组操作构成的可靠、独立的工作单元。事务具有以下特点:?Atomicity(原子性)?Consistency(一致性)?Isolation(隔离性)?Durability(持久性)2.事务的一致性单体应用可以在数据库的... 查看详情

springcloud构建全球多租户分布式微服务部署的方案

参考技术A最近在用springcloud分布式微服务云架构做一个全球多租户分布式部署的方案,我在这里只是简单的记录,当前的架构图只能是一个大概的方案,具体实施的方案和细节,IT老铁们可以自己去揣摩,因为业务链不同,细节... 查看详情

springcloud微服务实战搭建企业级应用开发框架:架构说明

SpringCloud分布式应用微服务系统架构图:SpringCloud分布式应用微服务系统组件列表:微服务框架组件:SpringBoot2+SpringCloudHoxton.SR8+SpringCloudAlibabaSpringBootAdmin:管理和监控SpringBoot应用程序的微服务健康状态数据持久化组件:MySql+Druid+My... 查看详情

阅读书单2020

...代的数据处理与机器学习基础:从入门到求职vim实用技巧SpringCloud微服务实战深入起初HTTPS:从原理到实战 查看详情

微服务springcloud+docker入门到高级实战

第一章课程介绍和学习路线1、微服务架构SpringCloud课程介绍简介:课程介绍和课程大纲讲解,讲课风格和重点内容理解技巧2、技术选型和学后水平简介:课程所需基础和技术选型讲解,学完课程可以到达怎样的程度,第二章架... 查看详情

jmeter性能测试视频

jmeter性能测试视频 后端开发:1、2017龙果微服务架构的分布式事务解决方案2、2017年龙果springboot入门实战视频教程-首套中文教程3、51CTOSpringBoot实战与原理分析视频课程4、ElasticSearch5视频教程5、Elasticsearch顶尖高手系列:高手... 查看详情

微服务springcloud+docker入门到高级实战(目录)

 第一章课程介绍和学习路线1、微服务架构SpringCloud课程介绍 简介:课程介绍和课程大纲讲解,讲课风格和重点内容理解技巧2、技术选型和学后水平 简介:课程所需基础和技术选型讲解,学完课程可以到达怎样的程度,第二... 查看详情

最终一致分布式事务方案解析

...服务间互相调用通常通过RPC(Dubbo)或HttpAPI(SpringCloud)进行,所以已经无法使用TM统一管理微服务的RM。不同的微服务使用的数据源类型可能完全不同,如果微服务使用了NoSQL之类不支持事务的数据库,... 查看详情

springcloud分布式事务管理

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

3.14go微服务实战(微服务理论)---微服务中的分布式事务管理

第14章 微服务中的分布式事务管理14.1 微服务下的事务管理 14.1.1 面临的难题 14.1.2 SRP的折衷14.2 微服务中处理事务的几种方式 用来管理事务的方法或者原则有很多种,如下: 1.避免使用跨服务的事务; 2.两部提交法,分... 查看详情