简介
在当前互联网的环境下，消息队列的使用越来越广泛。而 Apache Kafka 则是其中非常受欢迎的一种消息队列软件。针对 Kafka 的 Java 客户端在使用上是非常方便的，但对于其它语言的客户端，如Node.js，就需要依靠第三方库来进行接入。而 egg-kafka-java-bridge 库则是一个非常好的可选方案。
egg-kafka-java-bridge 库可以使你在 Node.js 中封装和调用 Kafka Java 客户端。这种方式的优点是可以直接使用 Java 客户端提供的特性，同时可以更好的控制和调优 Kafka 客户端的行为。
egg-kafka-java-bridge 使用教程
接下来，将介绍 egg-kafka-java-bridge 的使用教程。
安装 egg-kafka-java-bridge
使用 npm 来安装 egg-kafka-java-bridge：
npm install --save egg-kafka-java-bridge
引入 egg-kafka-java-bridge
在 Egg.js 项目的 config/plugin.js 中，添加以下配置：
module.exports = {
kafkaJava: {
enable: true,
package: 'egg-kafka-java-bridge',
},
};配置 egg-kafka-java-bridge
在 Egg.js 项目的 config/config.default.js 中，添加以下配置：
exports.kafkaJava = {
kafkaClient: {
'bootstrap.servers': 'localhost:9092',
},
};在 Egg.js 项目启动时，Kafka 客户端就会被初始化。
发送和消费消息
发送消息
使用以下代码来发送消息：
-- -------------------- ---- -------
----- -------- ------------- -
----- ----- - --------------------
----- -------- - -----------------
----- -------------------
----- ---------------
------ -------
--------- -
- ---- ------- ------ ------- --
--
---
----- ----------------------
-使用上述代码，可以连接到本地 Kafka 实例，并向 test topic 发送一个消息。
消费消息
egg-kafka-java-bridge 允许使用以下两种方式来消费消息：
方式一：使用 Consumer API
-- -------------------- ---- -------
----- -------- ----------------- -
----- ----- - --------------------
----- -------- - ---------------- -------- ------------ ---
----- -------------------
----- -------------------- ------ ------- -------------- ---- ---
----- --------------
------------ -- ------ ---------- ------- -- -- -
-------------
---- -----------------------
------ -------------------------
---
--
---
----- ----------------------
-使用上述代码，可以连接到本地 Kafka 实例，并从 test topic 消费消息，并在控制台输出消费的消息。
方式二：使用 Consumer Stream API
-- -------------------- ---- -------
----- -------- ----------------- -
----- ----- - --------------------
----- -------- - ---------------------- -------- ------------ ---
----- -------------------
----- -------------------- ------ ------- -------------- ---- ---
-------------------------- --------- -- -
-------------
---- -----------------------
------ -------------------------
---
---
----- -------------------------------- -- -
--------------------- -- ---------------
---
-使用上述代码，同样可以连接到本地 Kafka 实例，并从 test topic 消费消息，并在控制台输出消费的消息。
总结
egg-kafka-java-bridge 库的出现，可以使 Node.js 项目更好的使用 Kafka 的能力，同时也可以避免自己去编写完整的消息队列客户端。掌握了 egg-kafka-java-bridge 的使用方式，可以极大地方便你在 Node.js 项目中使用 Kafka。
完整示例代码请参考 egg-kafka-java-bridge-demo。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/60055ebf81e8991b448dc7d7