Tenlion/wg-gateway-manage
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试功能

Browse Source
This commit is contained in:
wanggeng 2021-12-22 21:05:29 +08:00
parent 2073049b66
commit d05ec05843
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/resources/application-test.yml
View File

@ -53,7 +53,7 @@ spring:
connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000 connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
use-global-data-source-stat: true use-global-data-source-stat: true
kafka: kafka:
bootstrap-servers: 192.168.0.103:9092 bootstrap-servers: 192.168.0.156:9093
producer: producer:
# 写入失败时，重试次数。当leader节点失效，一个repli节点会替代成为leader节点，此时可能出现写入失败， # 写入失败时，重试次数。当leader节点失效，一个repli节点会替代成为leader节点，此时可能出现写入失败，
# 当retris为0时，produce不会重复。retirs重发，此时repli节点完全成为leader节点，不会产生消息丢失。 # 当retris为0时，produce不会重复。retirs重发，此时repli节点完全成为leader节点，不会产生消息丢失。

14
src/test/java/ink/wgink/wggatewaymanage/WgGatewayManageApplicationTests.java
View File

@ -1,13 +1,25 @@
package ink.wgink.wggatewaymanage; package ink.wgink.wggatewaymanage;
import ink.wgink.gatewaymanage.WgGatewayManageApplication;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
@SpringBootTest @RunWith(SpringRunner.class)
@SpringBootTest(classes = WgGatewayManageApplication.class)
@ActiveProfiles("test")
class WgGatewayManageApplicationTests { class WgGatewayManageApplicationTests {
@Autowired
private KafkaTemplate kafkaTemplate;
@Test @Test
void contextLoads() { void contextLoads() {
kafkaTemplate.send("tableSync", "{\"tableNumber\":\"C0001\",\"uid\":\"123\",\"action\":\"save\",\"data\":{\"case_code\":\"985\",\"case_description\":\"案件描述\"}}");
} }
} }