如何通过nodeJs执行NestJs TCP微服务命令

发布于 2025-01-09 05:19:48 字数 1178 浏览 0 评论 0原文

我有一个基于 https://docs.nestjs.com/microservices/basics< 的工作微服务（MS） /a> 使用 TCP 协议。通过实现 @nestjs/microservices 客户端，从我的 NestJS API 执行命令很容易。

现在我正在使用普通的nodeJs 来处理 Lambda (AWS)，该 lambda 包含一个还需要向 MS 发送命令的函数。我尝试使用 net 创建一个套接字来发送命令（字符串化），但它不会触发任何内容。我的示例nodeJs代码：

const net = require('net');
const saveProducts = (products) => {
  let socket = new net.Socket();
  socket.setEncoding('UTF8');
  socket.on('data', function (data) {
    console.log('ON DATA'); // print out data
    console.log(data.toString()); // print out data
  });

  socket.connect(options.port, options.host, function () {
    //called when connection is created
    const command = JSON.stringify({ pattern: { cmd: 'update-many', ctrl: 'product' } });
    socket.write(command, 'UTF8', function (err) {
      console.log(err);
    });
  });
}

我使用网络嗅探器来获取示例消息结构..

类似的问题，但建议只是添加@nestjs/microservices，我想知道如果没有它该怎么做。

原文

I have a working Microservice(MS) based on https://docs.nestjs.com/microservices/basics using a TCP protocol. Executing a command from my NestJS API was easy by implementing the @nestjs/microservices Client.

Now im working on a Lambda (AWS) in plain nodeJs, this lambda contains a function that also need to send a command to the MS. I tried using net to create a Socket to send a command (stringified) but it doesn't trigger anything.
my example nodeJs code:

const net = require('net');
const saveProducts = (products) => {
  let socket = new net.Socket();
  socket.setEncoding('UTF8');
  socket.on('data', function (data) {
    console.log('ON DATA'); // print out data
    console.log(data.toString()); // print out data
  });

  socket.connect(options.port, options.host, function () {
    //called when connection is created
    const command = JSON.stringify({ pattern: { cmd: 'update-many', ctrl: 'product' } });
    socket.write(command, 'UTF8', function (err) {
      console.log(err);
    });
  });
}

I have used a network sniffer to get an example message structure..

similar issue but the suggestion is only to add @nestjs/microservices, I was wondering how to do it without it.

分享到QQ

分享到微博