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



    4.0.0

    com.itmentu
    skywalking-order
    1.0-SNAPSHOT

    
    
        org.springframework.boot
        spring-boot-starter-parent
        2.3.8.RELEASE
    

    
        
        1.8
        
        true
        1.18.8
        3.1.1
    

    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            mysql
            mysql-connector-java
        
        
            com.baomidou
            mybatis-plus-boot-starter
            ${mybatis.plus.version}
        
        
        
            org.projectlombok
            lombok
            ${lombok.version}
            provided
        
        
            log4j
            log4j
            1.2.17

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 {
}

接口实现类:com.itmentu.service.impl.OrderServiceImpl

@Service
public class OrderServiceImpl extends ServiceImpl implements OrderService {
}

6)Mapper

创建com.itmentu.mapper.OrderMapper

public interface OrderMapper extends baseMapper {
}

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



    4.0.0

    com.itmentu
    skywalking-item
    1.0-SNAPSHOT

    
    
        org.springframework.boot
        spring-boot-starter-parent
        2.3.8.RELEASE
    

    
        
        1.8
        
        true
        1.18.8
        3.1.1
    

    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            mysql
            mysql-connector-java
        
        
            com.baomidou
            mybatis-plus-boot-starter
            ${mybatis.plus.version}
        
        
        
            org.projectlombok
            lombok
            ${lombok.version}
            provided
        
        
            log4j
            log4j
            1.2.17

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 {
    Integer incr(Integer id, Integer count);
}

接口实现类:com.itmentu.service.impl.ItemServiceImpl

@Service
public class ItemServiceImpl extends ServiceImpl 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 {
    @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 探针下载

程序要想实现数据收集，第一步就是需要下载探针，下载地址;https://skywalking.apache.org/downloads/

下载后，我们把文件解压放到D:devinstallitmentu，如下图：

我们主要关注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

SpringBoot工程集成Skywalking

Java相关栏目本月热门文章