Skip to content

Commit 0f378bf

Browse files
enjoyCoding666enjoyCoding666
committed
kafkaDemo添加logback日志配置
1 parent 7f2e8cd commit 0f378bf

9 files changed

Lines changed: 78 additions & 14 deletions

File tree

‎kafka/pom.xml‎

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,10 +30,14 @@
3030
<groupId>org.springframework.boot</groupId>
3131
<artifactId>spring-boot-starter-web</artifactId>
3232
</dependency>
33-
<dependency>
34-
<groupId>org.springframework.boot</groupId>
35-
<artifactId>spring-boot-starter</artifactId>
36-
</dependency>
33+
34+
35+
<!--使用log4j2-->
36+
<!--<dependency>-->
37+
<!--<groupId>org.springframework.boot</groupId>-->
38+
<!--<artifactId>spring-boot-starter-log4j2</artifactId>-->
39+
<!--<version>1.3.8.RELEASE</version>-->
40+
<!--</dependency>-->
3741
<dependency>
3842
<groupId>org.springframework.kafka</groupId>
3943
<artifactId>spring-kafka</artifactId>

‎kafka/src/main/java/com/example/demo/KafkaDemo1.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public static void main(String[] args) throws Exception {
1515
ConfigurableApplicationContext context= SpringApplication.run(KafkaDemo1.class,args);
1616
KafkaProducer kafkaProducer=(KafkaProducer) context.getBean("kafkaProducer");
1717

18-
for(int i=0;i<10;i++) {
18+
for(int i=0;i<5;i++) {
1919
kafkaProducer.kafkaSend();
2020
Thread.sleep(3000);
2121
}

kafka/src/main/java/com/example/demo/demo1/KafkaDemoApplication.java renamed to kafka/src/main/java/com/example/demo/KafkaInMvc.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package com.example.demo.demo1;
1+
package com.example.demo;
22

33
import org.springframework.boot.SpringApplication;
44
import org.springframework.boot.autoconfigure.SpringBootApplication;
55

66
@SpringBootApplication
7-
public class KafkaDemoApplication {
7+
public class KafkaInMvc {
88

99
public static void main(String[] args) {
10-
SpringApplication.run(KafkaDemoApplication.class, args);
10+
SpringApplication.run(KafkaInMvc.class, args);
1111
}
1212
}

‎kafka/src/main/java/com/example/demo/demo1/KafkaConsumer.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@
99
import org.springframework.kafka.annotation.KafkaListener;
1010
import org.springframework.stereotype.Component;
1111

12+
13+
1214
@Component
1315
public class KafkaConsumer {
1416

‎kafka/src/main/java/com/example/demo/demo1/KafkaProducer.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ public void kafkaSend() throws Exception {
2727
UserAccount userAccount=new UserAccount();
2828
userAccount.setCard_name("cardName");
2929
userAccount.setAddress("address");
30-
logger.debug("尝试使用kafka发送信息：");
30+
logger.debug("使用kafka发送信息：");
3131
ListenableFuture send = kafkaTemplate.send("test", "key", JSON.toJSONString(userAccount));
3232

3333
}

‎kafka/src/main/java/com/example/demo/demo1/SystemController.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ public class SystemController {
2121

2222
@RequestMapping(value = "/kafka/send", method = RequestMethod.GET)
2323
public void warnInfo() throws Exception {
24-
int count = 10;
24+
int count = 5;
2525
for (int i = 0; i < count; i++) {
2626
kafkaProducer.kafkaSend();
2727
}

‎kafka/src/main/resources/application.properties‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
server.port=8090
22

3+
####### logback
4+
logging.config=classpath:logback-spring.xml
5+
36
####### kafka
47

58
### producer ÅäÖÃ
@@ -17,4 +20,5 @@ spring.kafka.consumer.auto-commit-interval=100
1720
spring.kafka.consumer.max-poll-records=1
1821
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
1922
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
20-
spring.kafka.listener.concurrency=5
23+
spring.kafka.listener.concurrency=5
24+

‎kafka/src/main/resources/logback-spring.xml‎

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<configuration>
3+
<include resource="org/springframework/boot/logging/logback/base.xml"/> <!-- logback 提供的基本配置 -->
4+
5+
<!-- 控制台 -->
6+
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
7+
<encoder>
8+
<Pattern>[%-5level] %d{yyyy-MM-dd HH:mm:ss} %logger{36} %line: %msg %n</Pattern> <!-- 输出格式 -->
9+
<charset>UTF-8</charset> <!-- 解决中文乱码问题 -->
10+
</encoder>
11+
</appender>
12+
13+
<!--log文件-->
14+
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
15+
　<file>log.log</file>
16+
<append>true</append>
17+
<encoder>
18+
　 　<pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] [%-5level] %logger{35} - %msg%n</pattern>
19+
<charset>UTF-8</charset> <!-- 解决中文乱码问题 -->
20+
</encoder>
21+
</appender>
22+
23+
<!--记录到文件 (每天一个文件) -->
24+
<appender name="dailyRollingFileAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
25+
<File>log/spring-boot-blog.log</File> <!-- 最新的log文件名 -->
26+
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
27+
<FileNamePattern>log/spring-boot-project.%d{yyyy-MM-dd}.log</FileNamePattern> <!-- 历史文件名 -->
28+
<maxHistory>30</maxHistory> <!-- 保留 30 天的日志 -->
29+
</rollingPolicy>
30+
<encoder>
31+
<Pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{35} : %n %msg %n</Pattern>
32+
<charset>UTF-8</charset> <!--解决中文乱码问题-->
33+
</encoder>
34+
</appender>
35+
36+
<!-- 将上面两个 appender 关联到我们的项目 -->
37+
<logger name="com.example.demo" level="DEBUG" additivity="false"> <!-- name 是项目包名，为了方便调试，输出 DEBUG 级别及其以上的log -->
38+
<appender-ref ref="CONSOLE"/>
39+
<appender-ref ref="FILE" />
40+
<!--<appender-ref ref="dailyRollingFileAppender" />-->
41+
</logger>
42+
43+
<!-- 其他框架的日志输出 -->
44+
<property name="LOG_FILE" value="log/spring-boot-tmp.log" />
45+
<logger name="org.springframework.web" level="INFO"/> <!-- spring web 包下的 logger, 只输出 INFO 级别的 -->
46+
<logger name="org.springframework.boot.web.filter" level="INFO"/>
47+
</configuration>

‎zookeeper/src/main/java/com/example/demo/MyZkSerializer.java‎

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,19 @@
66

77

88
public class MyZkSerializer implements ZkSerializer {
9-
public Object deserialize(byte[] bytes) throws ZkMarshallingError {
10-
return new String(bytes, Charsets.UTF_8);
11-
}
9+
/**
10+
* 序列化，将对象转化为字节数组
11+
*/
1212
public byte[] serialize(Object obj) throws ZkMarshallingError {
1313
return String.valueOf(obj).getBytes(Charsets.UTF_8);
1414
}
15+
16+
/**
17+
* 反序列化，将字节数组转化为UTF_8字符串
18+
*/
19+
public Object deserialize(byte[] bytes) throws ZkMarshallingError {
20+
return new String(bytes, Charsets.UTF_8);
21+
}
1522
}
1623

1724

0 commit comments

Comments
 (0)