如何快速上手microservice-kafkaJava Maven Docker开发环境搭建与首次运行分步教程【免费下载链接】microservice-kafkaDemo to show how Apache Kafka can be used for communication between microservices项目地址: https://gitcode.com/gh_mirrors/mi/microservice-kafkamicroservice-kafka 是一个用 Java 编写的微服务示例项目演示如何基于 Apache Kafka 实现订单Order、发货Shipping和开票Invoicing三个微服务之间的消息通信。本文是一份面向新手的分步教程从安装 JDK 和 Docker到用 Maven 构建项目、用 Docker Compose 一键启动全部容器最后访问本地页面完成你的第一笔跨服务订单。全程约 20 分钟。项目长什么样3个微服务 Kafka 消息总线先理解整体结构跑起来后你才知道在看什么组件角色本地访问端口Apache httpd统一入口转发 HTTP 请求8080Order 订单服务创建订单用KafkaTemplate向 Kafka 发消息8081Shipping 发货服务用KafkaListener消费消息生成发货单8082Invoicing 开票服务用KafkaListener消费消息生成发票8083Kafka Zookeeper消息队列与协调容器内部 9092Postgres每个微服务各用一个独立数据库容器内部 5432所有订单数据都进入名为order的 topic5 个分区发货与开票各自使用独立的消费者组因此可以横向扩展多实例并行消费。三个微服务的代码分别位于订单microservice-kafka/microservice-kafka-order/发货microservice-kafka/microservice-kafka-shipping/开票microservice-kafka/microservice-kafka-invoicing/容器编排定义在 docker/docker-compose.yml官方运行说明见 HOW-TO-RUN.md。第一步安装 Java JDK 与 Docker2个必备工具本项目基于 Java 17 和 Spring Boot 3.0.6见根 pommicroservice-kafka/pom.xml需要JDK不是 JRE安装后确认命令行能执行java和javac。Docker Community Edition安装后确认能执行docker。Docker Compose确认能执行docker-compose较新版本的 Docker 中写作docker compose。内存配置容器较多请在 Docker 设置Preferences → Advanced中为 Docker 分配4 GB 内存否则容器可能因内存不足被杀掉。第二步克隆仓库并用 Maven 构建约2分钟克隆代码项目仓库地址https://gitcode.com/gh_mirrors/mi/microservice-kafka git clone https://gitcode.com/gh_mirrors/mi/microservice-kafka进入microservice-kafka/microservice-kafka目录执行项目自带的 Maven Wrapper 构建首次会下载依赖需要等待cd microservice-kafka ./mvnw clean package # Windows 下使用 mvnw.cmd clean package看到BUILD SUCCESS即成功三个微服务会各生成一个可执行 jar 包。构建失败怎么办常见4个原因端口冲突测试占用了本机 9092Kafka和 8080HTTP等端口请先停掉占用它们的程序跳过测试构建./mvnw clean package -Dmaven.test.skiptrue删除主目录下.m2中的settings.xml如果其中配置了特殊 Maven 仓库依赖下载异常删除主目录下.m2/repository目录后重新构建让依赖全部重新下载。第三步Docker Compose 构建并启动7个容器进入docker目录先构建镜像会拉取基础镜像并安装软件需要一些时间cd docker docker-compose build构建完成后用docker images应能看到mskafka_前缀的镜像mskafka_order、mskafka_shipping、mskafka_invoicing、mskafka_postgres、mskafka_apache等。然后后台启动所有容器docker-compose up -d首次启动会自动下载 Zookeeper 和 Kafka 的基础镜像。用docker ps检查应看到 7 个容器全部处于Up状态zookeeper、kafka、postgres、apache、order、shipping、invoicing。第四步首次运行——创建一笔订单看消息如何流动 打开浏览器访问http://localhost:8080/首页有三个入口Order进入订单服务选择客户和商品创建一个订单稍等片刻切换到Shipping可以看到这笔订单已自动生成发货单再切换到Invoicing对应发票也已生成。整个过程中订单服务并没有直接调用发货和开票服务——它只是把订单以 JSON 格式发到 Kafka 的ordertopic另外两个服务各自监听并按需取数开票服务只读取开票所需字段发货服务只读取发货所需字段。这正是微服务之间无代码依赖通信的典型方式。验证 Kafka 中确实有消息可以进入 Kafka 容器查看 topic 内容docker exec -it mskafka_kafka_1 /bin/sh kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic order --from-beginning进阶玩法扩展消费者实例一行命令由于发货和开票使用独立消费者组你可以直接扩展实例数量来观察分区如何被分配docker-compose scale shipping2 docker logs mskafka_shipping_1日志会显示每个实例分别监听哪些分区、消费哪些记录——这是理解 Kafka 分区与消费者组最直观的方式。收尾优雅停止与清理docker-compose down # 停止所有容器 docker-compose rm # 删除已停止的容器两条命令组合即可回到干净的全新起点随时重新up再跑一遍。排错速查表5个高频问题现象原因与解决容器启动后立刻退出docker ps -a查看已终止容器docker logs 容器名看日志日志中出现killedDocker 内存不足把内存调到 4 GB 后重启构建卡在测试阶段加-Dmaven.test.skiptrue跳过测试首页 8080 打不开检查mskafka_apache_1容器是否在运行微服务页面空白查看对应容器日志多为连接 Kafka/Postgres 的时序问题重启该服务即可总结到这里你已经完成了 microservice-kafka 的完整上手路径安装 JDK Docker → Maven 构建 → Docker Compose 启动 → 创建订单验证消息流。项目虽小却浓缩了微服务架构中最关键的几个实践消息解耦、JSON 柔性契约、独立数据库、按消费者组扩展。建议下一步阅读 README.md 中Remarks on the Code部分看看订单数据是如何被复制而非共享到下游服务的——这是理解微服务数据一致性的绝佳切入点。【免费下载链接】microservice-kafkaDemo to show how Apache Kafka can be used for communication between microservices项目地址: https://gitcode.com/gh_mirrors/mi/microservice-kafka创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考