微服務分散式事務實戰（五）準備資料庫和建立第一個微服務
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 ‘板塊描述\n’,
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 ,阿里連線池) ,
服務中心客戶端。
<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 =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;
}
//
@RequestMapping(value = "/saveBlock", method = RequestMethod.GET)
public String saveBlock() {
//呼叫服務
Integer result=blockService.saveBlock("aa", "aa");
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）測試
啟動註冊中心，啟動微服務
然後啟動瀏覽器
