springCloud分布式事务实战(五)准备数据库和创建第一个微服务
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了springCloud分布式事务实战(五)准备数据库和创建第一个微服务,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含6890字,纯文字阅读大概需要10分钟。
内容图文
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 {@Autowired<br/" rel="nofollow">br/>@Autowired<br/private BlockDao blockDao;
@Override
public List<Block> getBlockList() {
return blockDao.getBlockList();}
*/
@Override<br/" rel="nofollow">br/>}
*/
@Override<br/public int saveBlock(String bName, String bDescription)
{
int rs1 = blockDao.saveBlock("jwg1", "111");// 保存1
return rs1;
}
}
(6)编写控制层
package com.jh.controller;@RestController<br/" rel="nofollow">br/>@RestController<br/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分布式事务实战(五)准备数据库和创建第一个微服务
标签:第一个 图片 hot 开启 main select ice love 属性
本文系统来源:http://blog.51cto.com/14048134/2310798
内容总结
以上是互联网集市为您收集整理的springCloud分布式事务实战(五)准备数据库和创建第一个微服务全部内容,希望文章能够帮你解决springCloud分布式事务实战(五)准备数据库和创建第一个微服务所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。