公司网站开发与维护百度网站与推广

公司网站开发与维护,百度网站与推广,佛山营销型网站定制,生活服务类网站开发视频看了几百小时还迷糊#xff1f;关注我#xff0c;几分钟让你秒懂#xff01;一、为什么我们需要 Kafka#xff1f;在现代微服务架构中#xff0c;系统之间的通信不能总是“你等我、我等你”——这会导致性能瓶颈甚至雪崩。Kafka 就是一个高性能、高吞吐、可扩展的消息…视频看了几百小时还迷糊关注我几分钟让你秒懂一、为什么我们需要 Kafka在现代微服务架构中系统之间的通信不能总是“你等我、我等你”——这会导致性能瓶颈甚至雪崩。Kafka 就是一个高性能、高吞吐、可扩展的消息中间件它能帮我们实现解耦生产者和消费者互不干扰。削峰填谷流量高峰时缓存消息避免系统崩溃。异步处理比如用户注册后发邮件、记录日志等非核心操作可以异步完成。 典型应用场景用户行为日志收集如点击、浏览订单系统异步通知库存、物流微服务间事件驱动通信二、Spring Boot 集成 Kafka 快速上手✅ 步骤 1添加依赖pom.xmldependency groupIdorg.springframework.kafka/groupId artifactIdspring-kafka/artifactId /dependency注意Spring Boot 2.7 默认支持 Kafka 3.x无需额外指定版本。✅ 步骤 2配置 Kafkaapplication.ymlspring: kafka: bootstrap-servers: localhost:9092 producer: key-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.springframework.kafka.support.serializer.JsonSerializer consumer: group-id: my-group key-deserializer: org.apache.kafka.commonserialization.StringDeserializer value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer properties: spring.json.trusted.packages: *⚠️spring.json.trusted.packages是安全设置防止反序列化攻击。生产环境应指定具体包名如com.example.dto。✅ 步骤 3定义消息实体类public class UserEvent { private String userId; private String action; // 如 REGISTER, LOGIN // 构造函数、getter/setter 省略建议用 Lombok }✅ 步骤 4生产者发送消息Service public class KafkaProducerService { Autowired private KafkaTemplateString, UserEvent kafkaTemplate; public void sendUserEvent(String topic, UserEvent event) { kafkaTemplate.send(topic, event.getUserId(), event); System.out.println( 消息已发送: event); } }✅ 步骤 5消费者接收消息Component public class KafkaConsumerService { KafkaListener(topics user-events, groupId my-group) public void listen(UserEvent event) { System.out.println( 收到消息: event); // 模拟业务处理发邮件、写日志等 } }✅ 步骤 6Controller 测试接口RestController RequestMapping(/kafka) public class KafkaTestController { Autowired private KafkaProducerService producerService; PostMapping(/send) public String send(RequestParam String userId, RequestParam String action) { UserEvent event new UserEvent(); event.setUserId(userId); event.setAction(action); producerService.sendUserEvent(user-events, event); return 消息已发送; } }启动 Kafka本地可用 Dockerdocker run -p 9092:9092 --name kafka \ -e KAFKA_BROKER_ID0 \ -e KAFKA_ZOOKEEPER_CONNECTlocalhost:2181 \ -e KAFKA_ADVERTISED_LISTENERSPLAINTEXT://localhost:9092 \ -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR1 \ bitnami/kafka:latest如果没有 Zookeeper可使用 Kafka 3.3 的 KRaft 模式无 Zookeeper但初学者建议先用传统方式。三、反例 常见错误避坑指南❌ 反例 1忽略消费者组group.id// 错误没指定 groupId多个实例会重复消费 KafkaListener(topics user-events) public void badListener(UserEvent event) { ... }✅ 正确做法明确指定groupId同一组内消息只会被一个消费者处理。❌ 反例 2序列化配置错误# 错误value-serializer 写成 StringSerializer但传的是对象 spring: kafka: producer: value-serializer: org.apache.kafka.common.serialization.StringSerializer结果ClassCastException或SerializationException。✅ 正确对象用JsonSerializer字符串用StringSerializer。❌ 反例 3消费者处理异常未捕获KafkaListener(topics user-events) public void riskyListener(UserEvent event) { // 如果这里抛异常消息会不断重试默认无限重试 someRiskyOperation(); }✅ 解决方案加 try-catch或配置死信队列DLQBean public ConsumerFactoryString, UserEvent consumerFactory() { MapString, Object props new HashMap(); // ... 其他配置 props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ErrorHandlingDeserializer.class); props.put(ErrorHandlingDeserializer.VALUE_DESERIALIZER_CLASS, JsonDeserializer.class); return new DefaultKafkaConsumerFactory(props); }更推荐使用RetryableTopicSpring Kafka 2.7自动重试并转发到 DLQ。四、注意事项生产环境必看主题Topic提前创建虽然 Kafka 支持自动创建但生产环境建议手动创建并设置分区数、副本数。幂等性设计消费者可能重复收到消息如重试业务逻辑需保证幂等如用数据库唯一索引。监控与告警使用 Kafka Manager、Prometheus Grafana 监控堆积情况。不要在消费者里做耗时操作否则会阻塞后续消息拉取可提交偏移量后异步处理。五、总结Kafka 在 Spring Boot 中集成非常简单但细节决定成败。只要注意序列化、消费者组、异常处理和幂等性就能构建出稳定可靠的消息系统。视频看了几百小时还迷糊关注我几分钟让你秒懂