result) {
+ log.info("发送消息成功, 消息: {}", result.toString());
+ }
+ });
+ }
+}
diff --git a/dev-protocol-log/src/main/resources/application.yml b/dev-protocol-log/src/main/resources/application.yml
new file mode 100644
index 0000000..88fd0e9
--- /dev/null
+++ b/dev-protocol-log/src/main/resources/application.yml
@@ -0,0 +1,58 @@
+server:
+ servlet:
+ context-path: /kafka
+ port: 8001
+
+# Spring整合Kafka的整合选项
+spring:
+ kafka:
+ # todo 公网访问端口,这里没开
+ bootstrap-servers: 121.89.208.118:9092,39.103.195.38:9092,39.103.188.57:9092
+ # 生产者
+ producer:
+ # kafka producer 发送消息失败的一个重试的次数
+ retries: 0
+ # 批量发送数据的配置
+ batch-size: 16384
+ # 设置 kafka 生产者内存缓冲区的大小(32M)
+ buffer-memory: 33554432
+ # 设置 kafka 消息的序列化配置
+ key-serializer: org.apache.kafka.common.serialization.StringSerializer
+ value-serializer: org.apache.kafka.common.serialization.StringSerializer
+ # kafka 生产端最重要的选项,
+ # acks=0 表示生产者在成功写入消息之前不会等待任何来自服务器的响应
+ # acks=1 只要集群的首领节点收到消息,生产者就会收到来自服务器成功响应
+ # acks=-1 表示分区leader必须等待消息被成功写入到所有的ISR副本（同步副本）中才认为produce请求成功，这种方案提供最高的消息持久性保证,但理论上吞吐率也是最差的。
+ acks: 1
+ # 消费者
+ consumer:
+ # todo 公网访问端口,这里没开
+ bootstrap-servers: 121.89.208.118:9092,39.103.195.38:9092,39.103.188.57:9092
+ # consumer 消息的签收机制: 手工签收
+ enable-auto-commit: false
+ # 该属性制定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理
+ # latest (默认值) 在偏移量无效的情况下，消费者姜葱最新的记录开始读取数据(在消费者启动之后生成的记录)
+ # earliest 在偏移量无效的情况下, 消费者从起始位置读取分区的记录
+ auto-offset-reset: earliest
+ # 序列化配置
+ key-deserializer: org.apache.kafka.common.serialization.StringSerializer
+ value-deserializer: org.apache.kafka.common.serialization.StringSerializer
+ listener:
+ # 手动ack方式进行确认
+ ack-mode: manual
+ # 并行度
+ concurrency: 5
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/dev-protocol-test/.gitignore b/dev-protocol-test/.gitignore
new file mode 100644
index 0000000..d4beec9
--- /dev/null
+++ b/dev-protocol-test/.gitignore
@@ -0,0 +1,46 @@
+### Example user template template
+### Example user template
+
+# IntelliJ project files
+.idea
+*.iml
+out
+gen
+### Maven template
+target/
+pom.xml.tag
+pom.xml.releaseBackup
+pom.xml.versionsBackup
+pom.xml.next
+release.properties
+dependency-reduced-pom.xml
+buildNumber.properties
+.mvn/timing.properties
+# https://github.com/takari/maven-wrapper#usage-without-binary-jar
+.mvn/wrapper/maven-wrapper.jar
+
+### Java template
+# Compiled class file
+*.class
+
+# Log file
+*.log
+
+# BlueJ files
+*.ctxt
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.nar
+*.ear
+*.zip
+*.tar.gz
+*.rar
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+
diff --git a/dev-protocol-test/pom.xml b/dev-protocol-test/pom.xml
new file mode 100644
index 0000000..9ad99f8
--- /dev/null
+++ b/dev-protocol-test/pom.xml
@@ -0,0 +1,34 @@
+
+
+
+ dev-protocol
+ org.example
+ 1.0-SNAPSHOT
+
+ 4.0.0
+
+ dev-protocol-test
+
+
+ 8
+ 8
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+
+ org.junit.vintage
+ junit-vintage-engine
+
+
+
+
+
+
\ No newline at end of file
diff --git a/dev-protocol-test/src/main/java/com/baiye/service/DemoTestService.java b/dev-protocol-test/src/main/java/com/baiye/service/DemoTestService.java
new file mode 100644
index 0000000..5572b46
--- /dev/null
+++ b/dev-protocol-test/src/main/java/com/baiye/service/DemoTestService.java
@@ -0,0 +1,14 @@
+package com.baiye.service;
+
+/**
+ * 演示测试服务
+ *
+ * ps: 一般不单独对 Dao/Model层进行单独的编写单元测试,对Service层进行测试
+ *
+ * @author q
+ * @date 2021/11/12
+ */
+public interface DemoTestService {
+
+ void oneOperation();
+}
diff --git a/dev-protocol-test/src/main/java/com/baiye/service/impl/DemoTestServiceImpl.java b/dev-protocol-test/src/main/java/com/baiye/service/impl/DemoTestServiceImpl.java
new file mode 100644
index 0000000..5bfb64d
--- /dev/null
+++ b/dev-protocol-test/src/main/java/com/baiye/service/impl/DemoTestServiceImpl.java
@@ -0,0 +1,10 @@
+package com.baiye.service.impl;
+
+import com.baiye.service.DemoTestService;
+
+public class DemoTestServiceImpl implements DemoTestService {
+ @Override
+ public void oneOperation() {
+
+ }
+}
diff --git a/dev-protocol-test/src/test/java/com/baiye/service/impl/DemoTestServiceImplTest.java b/dev-protocol-test/src/test/java/com/baiye/service/impl/DemoTestServiceImplTest.java
new file mode 100644
index 0000000..9540d3e
--- /dev/null
+++ b/dev-protocol-test/src/test/java/com/baiye/service/impl/DemoTestServiceImplTest.java
@@ -0,0 +1,31 @@
+package com.baiye.service.impl;
+
+
+class DemoTestServiceImplTest {
+
+
+ /*
+ * 常用的注解及说明
+ *
+ * @BeforeEach：在每个单元测试方法执行前都执行一遍
+ * @BeforeAll：在每个单元测试方法执行前执行一遍（只执行一次）
+ * @DisplayName("商品入库测试")：用于指定单元测试的名称
+ * @Disabled：当前单元测试置为无效，即单元测试时跳过该测试
+ * @RepeatedTest(n)：重复性测试，即执行n次
+ * @ParameterizedTest：参数化测试，
+ * @ValueSource(ints = {1, 2, 3})：参数化测试提供数据
+ */
+
+
+
+ /*
+ 测试这种类一: 使用断言进行定义
+
+ JUnit Jupiter提供了强大的断言方法用以验证结果，
+ 在使用时需要借助java8的新特性lambda表达式，均是来自org.junit.jupiter.api.Assertions包的static方法。
+ */
+
+
+
+
+}
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..fea1ca7
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,37 @@
+
+
+ 4.0.0
+
+ org.example
+ dev-protocol
+ pom
+ 1.0-SNAPSHOT
+
+ dev-protocol-test
+ dev-protocol-log
+
+
+
+ 8
+ 8
+
+ 2.3.2.RELEASE
+
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-dependencies
+ ${spring.boot.version}
+ pom
+ import
+
+
+
+
+
\ No newline at end of file