Skip to content

Commit cbb6c3e

Browse files
author
YunaiV
committed
增加 skywalking 示例
1 parent a94b3ad commit cbb6c3e

File tree

25 files changed

+464
-3
lines changed

25 files changed

+464
-3
lines changed

‎.gitignore‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ hs_err_pid*
2727
SpringBoot-Labs.ipr
2828
SpringBoot-Labs.iws
2929
target/**
30+
*.lst
3031
*.iml
3132
*ipr
32-
*.iws
33+
*.iws

‎lab-31/lab-31-rocketmq-demo/src/main/java/cn/iocoder/springboot/lab31/rocketmqdemo/consumer/Demo07Consumer.java‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package cn.iocoder.springboot.lab31.rocketmqdemo.consumer;
22

3-
import cn.iocoder.springboot.lab31.rocketmqdemo.message.Demo05Message;
43
import cn.iocoder.springboot.lab31.rocketmqdemo.message.Demo07Message;
54
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
65
import org.apache.rocketmq.spring.core.RocketMQListener;
@@ -11,7 +10,7 @@
1110
@Component
1211
@RocketMQMessageListener(
1312
topic = Demo07Message.TOPIC,
14-
consumerGroup = "demo07-consumer-group-" + Demo05Message.TOPIC
13+
consumerGroup = "demo07-consumer-group-" + Demo07Message.TOPIC
1514
)
1615
public class Demo07Consumer implements RocketMQListener<Demo07Message> {
1716

‎lab-39/lab-39-elasticsearch/pom.xml‎

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<groupId>org.springframework.boot</groupId>
7+
<artifactId>spring-boot-starter-parent</artifactId>
8+
<version>2.2.2.RELEASE</version>
9+
<relativePath/> <!-- lookup parent from repository -->
10+
</parent>
11+
<modelVersion>4.0.0</modelVersion>
12+
13+
<artifactId>lab-39-elasticsearch</artifactId>
14+
15+
<dependencies>
16+
<!-- 实现对 SpringMVC 的自动化配置 -->
17+
<dependency>
18+
<groupId>org.springframework.boot</groupId>
19+
<artifactId>spring-boot-starter-web</artifactId>
20+
</dependency>
21+
22+
<!-- 自动化配置 Spring Data Elasticsearch -->
23+
<dependency>
24+
<groupId>org.springframework.boot</groupId>
25+
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
26+
<version>2.2.1.RELEASE</version>
27+
</dependency>
28+
</dependencies>
29+
30+
</project>

‎lab-39/lab-39-elasticsearch/src/main/java/cn/iocoder/springboot/lab39/skywalkingdemo/ElasticsearchApplication.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package cn.iocoder.springboot.lab39.skywalkingdemo;
2+
3+
import org.springframework.boot.SpringApplication;
4+
import org.springframework.boot.autoconfigure.SpringBootApplication;
5+
6+
@SpringBootApplication
7+
public class ElasticsearchApplication {
8+
9+
public static void main(String[] args) {
10+
SpringApplication.run(ElasticsearchApplication.class, args);
11+
}
12+
13+
}

‎lab-39/lab-39-elasticsearch/src/main/java/cn/iocoder/springboot/lab39/skywalkingdemo/controller/DemoController.java‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
package cn.iocoder.springboot.lab39.skywalkingdemo.controller;
2+
3+
import cn.iocoder.springboot.lab39.skywalkingdemo.dataobject.ESUserDO;
4+
import org.springframework.beans.factory.annotation.Autowired;
5+
import org.springframework.data.mongodb.core.MongoTemplate;
6+
import org.springframework.data.mongodb.core.query.Criteria;
7+
import org.springframework.data.mongodb.core.query.Query;
8+
import org.springframework.web.bind.annotation.GetMapping;
9+
import org.springframework.web.bind.annotation.RequestMapping;
10+
import org.springframework.web.bind.annotation.RestController;
11+
12+
@RestController
13+
@RequestMapping("/demo")
14+
public class DemoController {
15+
16+
@Autowired
17+
private MongoTemplate mongoTemplate;
18+
19+
@GetMapping("/mongodb")
20+
public String mysql() {
21+
this.findById(1);
22+
return "mongodb";
23+
}
24+
25+
public ESUserDO findById(Integer id) {
26+
return mongoTemplate.findOne(new Query(Criteria.where("_id").is(id)), ESUserDO.class);
27+
}
28+
29+
}

‎lab-39/lab-39-elasticsearch/src/main/java/cn/iocoder/springboot/lab39/skywalkingdemo/dataobject/ESUserDO.java‎

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
package cn.iocoder.springboot.lab39.skywalkingdemo.dataobject;
2+
3+
import java.util.Date;
4+
5+
@Document(indexName = "user", // 索引名
6+
type = "user", // 类型。未来的版本即将废弃
7+
shards = 1, // 默认索引分区数
8+
replicas = 0, // 每个分区的备份数
9+
refreshInterval = "-1" // 刷新间隔
10+
)
11+
public class ESUserDO {
12+
13+
@Id
14+
private Integer id;
15+
/**
16+
* 账号
17+
*/
18+
private String username;
19+
/**
20+
* 密码
21+
*/
22+
private String password;
23+
/**
24+
* 创建时间
25+
*/
26+
private Date createTime;
27+
28+
@Override
29+
public String toString() {
30+
return "UserDO{" +
31+
"id=" + id +
32+
", username='" + username + '\'' +
33+
", password='" + password + '\'' +
34+
", createTime=" + createTime +
35+
'}';
36+
}
37+
38+
}

‎lab-39/lab-39-elasticsearch/src/main/resources/application.yml‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
server:
2+
port: 8079
3+
4+
spring:
5+
data:
6+
# Elasticsearch 配置项
7+
elasticsearch:
8+
cluster-name: elasticsearch # 集群名
9+
cluster-nodes: 127.0.0.1:9300 # 集群节点

‎lab-39/lab-39-mongodb/pom.xml‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<groupId>org.springframework.boot</groupId>
7+
<artifactId>spring-boot-starter-parent</artifactId>
8+
<version>2.2.2.RELEASE</version>
9+
<relativePath/> <!-- lookup parent from repository -->
10+
</parent>
11+
<modelVersion>4.0.0</modelVersion>
12+
13+
<artifactId>lab-39-mongodb</artifactId>
14+
15+
<dependencies>
16+
<!-- 实现对 SpringMVC 的自动化配置 -->
17+
<dependency>
18+
<groupId>org.springframework.boot</groupId>
19+
<artifactId>spring-boot-starter-web</artifactId>
20+
</dependency>
21+
22+
<!-- 自动化配置 Spring Data Mongodb -->
23+
<dependency>
24+
<groupId>org.springframework.boot</groupId>
25+
<artifactId>spring-boot-starter-data-mongodb</artifactId>
26+
</dependency>
27+
</dependencies>
28+
29+
</project>

‎lab-39/lab-39-mongodb/src/main/java/cn/iocoder/springboot/lab39/skywalkingdemo/MongoDBApplication.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package cn.iocoder.springboot.lab39.skywalkingdemo;
2+
3+
import org.springframework.boot.SpringApplication;
4+
import org.springframework.boot.autoconfigure.SpringBootApplication;
5+
6+
@SpringBootApplication
7+
public class MongoDBApplication {
8+
9+
public static void main(String[] args) {
10+
SpringApplication.run(MongoDBApplication.class, args);
11+
}
12+
13+
}

‎lab-39/lab-39-mongodb/src/main/java/cn/iocoder/springboot/lab39/skywalkingdemo/controller/DemoController.java‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
package cn.iocoder.springboot.lab39.skywalkingdemo.controller;
2+
3+
import cn.iocoder.springboot.lab39.skywalkingdemo.dataobject.UserDO;
4+
import org.springframework.beans.factory.annotation.Autowired;
5+
import org.springframework.data.mongodb.core.MongoTemplate;
6+
import org.springframework.data.mongodb.core.query.Criteria;
7+
import org.springframework.data.mongodb.core.query.Query;
8+
import org.springframework.web.bind.annotation.GetMapping;
9+
import org.springframework.web.bind.annotation.RequestMapping;
10+
import org.springframework.web.bind.annotation.RestController;
11+
12+
@RestController
13+
@RequestMapping("/demo")
14+
public class DemoController {
15+
16+
@Autowired
17+
private MongoTemplate mongoTemplate;
18+
19+
@GetMapping("/mongodb")
20+
public String mysql() {
21+
this.findById(1);
22+
return "mongodb";
23+
}
24+
25+
public UserDO findById(Integer id) {
26+
return mongoTemplate.findOne(new Query(Criteria.where("_id").is(id)), UserDO.class);
27+
}
28+
29+
}

0 commit comments

Comments
 (0)