SpringBoot工程集成Skywalking
1 案例准备
我们编写一个SpringBoot集成MyBatisPlus案例，实现下单操作，服务如下：
- skywalking-order 订单服务
- skywalking-item 商品服务
表结构如下:
-- ----------------------------
-- Table structure for tb_item
-- ----------------------------
DROP TABLE IF EXISTS `tb_item`;
CREATE TABLE `tb_item` (
`id` int(11) NOT NULL,
`title` varchar(200) NOT NULL COMMENT '商品名字',
`price` int(11) NOT NULL,
`count` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of tb_item
-- ----------------------------
INSERT INTO `tb_item` VALUES ('1', '华为P40', '8000', '10');
INSERT INTO `tb_item` VALUES ('2', '荣耀30S', '3500', '100');
-- ----------------------------
-- Table structure for tb_order
-- ----------------------------
DROP TABLE IF EXISTS `tb_order`;
CREATE TABLE `tb_order` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`item_id` int(11) NOT NULL COMMENT '商品ID',
`count` int(11) NOT NULL COMMENT '购买数量',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
复制代码
1.1 订单工程
我们创建普通的SpringBoot集成MyBatis实现对tb_order操作即可。
1)工程pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<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.itmentu</groupId>
<artifactId>skywalking-order</artifactId>
<version>1.0-SNAPSHOT</version>
<!-- 继承Spring boot工程 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.8.RELEASE</version>
</parent>
<properties>
<!--jdk版本-->
<java.version>1.8</java.version>
<!--跳过测试-->
<skipTests>true</skipTests>
<lombok.version>1.18.8</lombok.version>
<mybatis.plus.version>3.1.1</mybatis.plus.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>${mybatis.plus.version}</version>
</dependency>
<!-- lombok -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lombok.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
</dependencies>
</project>
复制代码
2)启动类
创建启动类com.itmentu.OrderApplication
@SpringBootApplication
@MapperScan(basePackages = "com.itmentu.mapper")
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class,args);
}
/***
* 创建
*/
@Bean
public RestTemplate restTemplate(){
return new RestTemplate();
}
}
复制代码
3)核心配置文件
创建application.yml，配置如下:
server:
port: 18081
spring:
datasource:
url: jdbc:mysql://localhost:3306/skywalking?serverTimezone=Asia/Shanghai&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull
driverClassName: com.mysql.jdbc.Driver
username: root
password: 123456
复制代码
4)Pojos
创建com.itmentu.pojos.Order，代码如下：
@Data
@TableName(value = "tb_order")
public class Order {
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
@TableField(value = "item_id")
private Integer itemId;
@TableField(value = "count")
private Integer count;
}
复制代码
5)Service
接口:com.itmentu.service.OrderService
public interface OrderService extends IService<Order> {
}
复制代码
接口实现类:com.itmentu.service.impl.OrderServiceImpl
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper,Order> implements OrderService {
}
复制代码
6)Mapper
创建com.itmentu.mapper.OrderMapper
public interface OrderMapper extends BaseMapper<Order> {
}
复制代码
7)Controller
创建控制器com.itmentu.controller.OrderController，代码如下:
@RestController
@RequestMapping(value = "/order")
public class OrderController {
@Autowired
private RestTemplate restTemplate;
@Autowired
private OrderService orderService;
/**
* 下单
*/
@PostMapping(value = "/{id}/{count}")
public String add(@PathVariable(value = "id")Integer id,
@PathVariable(value = "count")Integer count){
//1)递减库存
Integer hCount = restTemplate.getForObject("http://localhost:18082/item/1/1", Integer.class);
//2)下单
if(hCount>0){
Order order = new Order();
order.setCount(count);
order.setItemId(id);
orderService.save(order);
}
return "SUCCESS";
}
}
复制代码
1.2 商品工程
我们创建普通的SpringBoot集成MyBatis实现对tb_item操作即可。
1)工程pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<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.itmentu</groupId>
<artifactId>skywalking-item</artifactId>
<version>1.0-SNAPSHOT</version>
<!-- 继承Spring boot工程 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.8.RELEASE</version>
</parent>
<properties>
<!--jdk版本-->
<java.version>1.8</java.version>
<!--跳过测试-->
<skipTests>true</skipTests>
<lombok.version>1.18.8</lombok.version>
<mybatis.plus.version>3.1.1</mybatis.plus.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>${mybatis.plus.version}</version>
</dependency>
<!-- lombok -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lombok.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
</dependencies>
</project>
复制代码
2)启动类
创建启动类com.itmentu.ItemApplication
@SpringBootApplication
@MapperScan(basePackages = "com.itmentu.mapper")
public class ItemApplication {
public static void main(String[] args) {
SpringApplication.run(ItemApplication.class,args);
}
}
复制代码
3)核心配置文件
创建application.yml，配置如下:
server:
port: 18082
spring:
datasource:
url: jdbc:mysql://localhost:3306/skywalking?serverTimezone=Asia/Shanghai&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull
driverClassName: com.mysql.jdbc.Driver
username: root
password: 123456
复制代码
4)Pojos
创建com.itmentu.pojos.Item，代码如下：
@Data
@TableName(value = "tb_item")
public class Item {
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
@TableField(value = "title")
private String title;
@TableField(value = "price")
private Integer price;
@TableField(value = "count")
private Integer count;
}
复制代码
5)Service
接口:com.itmentu.service.ItemService
public interface ItemService extends IService<Item> {
Integer incr(Integer id, Integer count);
}
复制代码
接口实现类:com.itmentu.service.impl.ItemServiceImpl
@Service
public class ItemServiceImpl extends ServiceImpl<ItemMapper, Item> implements ItemService {
@Autowired
private ItemMapper itemMapper;
/**
* 库存递减
*/
@Override
public Integer incr(Integer id, Integer count) {
return itemMapper.updateItem(id,count);
}
}
复制代码
6)Mapper
创建com.itmentu.mapper.ItemMapper
public interface ItemMapper extends BaseMapper<Item> {
@Update("update tb_item set count=count-#{count} where id=#{id} and count>=#{count}")
Integer updateItem(@Param("id") Integer id,@Param("count") Integer count);
}
复制代码
7)Controller
创建控制器com.itmentu.controller.ItemController，代码如下:
@RestController
@RequestMapping(value = "/item")
public class ItemController {
@Autowired
private ItemService itemService;
/**
* 库存递减
*/
@GetMapping(value = "/{id}/{count}")
public Integer incrCount(@PathVariable(value = "id")Integer id,
@PathVariable(value = "count")Integer count){
return itemService.incr(id,count);
}
}
复制代码
2 集成Skywalking
使用IDEA集成，并将程序数据上传到Skywalking其实只需要配置启动参数即可，但如果是基于jar包集成，就需要使用命令集成了。
2.1 探针下载
程序要想实现数据收集，第一步就是需要下载探针，下载地址;skywalking.apache.org/downloads/
下载后，我们把文件解压放到D:\dev\install\itmentu\，如下图：
我们主要关注skywalking-agent.jar和config/agent.config文件，分别为探针文件以及核心配置文件，如下图：
2.2 IDEA使用agent探针
IDEA集成探针，只需要配置如下参数即可:
-javaagent:skywalking-agent.jar
-Dskywalking_config=agent.config
-Dskywalking.collector.backend_service=Skywalking OAP服务地址
-Dskywalking.agent.service_name=当前服务在Skywalking中注册的服务名字
复制代码
我们运行skywalking-item和skywalking-order的时候，加入上面参数即可，如下:
配置如下：
-javaagent:D:/dev/install/itmentu/apache-skywalking-apm-bin-es7/agent/skywalking-agent.jar
-Dskywalking_config=D:/dev/install/itmentu/apache-skywalking-apm-bin-es7/agent/config/agent.config
-Dskywalking.collector.backend_service=192.168.211.130:11800
-Dskywalking.agent.service_name=item
复制代码
我们把skywalking-order也按照上面方式配置一下:
-javaagent:D:/dev/install/itmentu/apache-skywalking-apm-bin-es7/agent/skywalking-agent.jar
-Dskywalking_config=D:/dev/install/itmentu/apache-skywalking-apm-bin-es7/agent/config/agent.config
-Dskywalking.collector.backend_service=192.168.211.130:11800
-Dskywalking.agent.service_name=order
复制代码
项目运行起来，我们再看各大服务拓扑图，效果如下：
2.3 生产环境集成
生产环境使用，因此我们需要将agent和每个项目的jar包上传到服务器上，上传apache-skywalking-apm-bin至/usr/local/server/skywalking，再将工程中的项目打包，并分别上传到服务器上，执行启动程序加上命令即可：
java -javaagent:/usr/local/server/skywalking/apache-skywalking-apm-bin/agent/skywalking-agent.jar -Dskywalking.agent.service_name=item -jar skywalking-item-1.0-SNAPSHOT.jar
复制代码
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
![[桜井宁宁]COS和泉纱雾超可爱写真福利集-一一网](https://www.proyy.com/skycj/data/images/2020-12-13/4d3cf227a85d7e79f5d6b4efb6bde3e8.jpg)
![[桜井宁宁] 爆乳奶牛少女cos写真-一一网](https://www.proyy.com/skycj/data/images/2020-12-13/d40483e126fcf567894e89c65eaca655.jpg)
