Невозможно отправить несколько сообщений UDP в узле js - PullRequest
Новая
       57

Невозможно отправить несколько сообщений UDP в узле js

0 голосов
/ 29 января 2019

Я пытаюсь понять dgram на небольшом примере клиент / сервер.Тем не менее, кажется, что я могу отправить только 1 сообщение за один прогон клиента.Если я пытаюсь отправить несколько сообщений, как в приведенном ниже коде клиента, ничего не отправляется.

Код сервера: 

var PORT = 16501;
var HOST = '127.0.0.1';

var dgram = require('dgram');
var server = dgram.createSocket('udp4');

server.on('listening', function () {
    var address = server.address();
    console.log('UDP Server: ' + address.address + ":" + address.port);
});

server.on('message', function (message, remote) {
    console.log('Received: ' + remote.address + ':' + remote.port +' - ' + message);

});

server.bind(PORT, HOST);

Код клиента: 

var PORT = 16501;
var HOST = '127.0.0.1';

var dgram = require('dgram');

var client = dgram.createSocket('udp4');

var i;

for(i=0;i<10;i++) {
    client.send('Test Message', 0, 12, PORT, HOST, function(err, bytes) {
        if (err) throw err;
        console.log('Send: ' + HOST +':'+ PORT);
    });
}
client.close();

Этот код клиентаработает, но может отправлять только 1 сообщение. 

var PORT = 16501;
var HOST = '127.0.0.1';

var dgram = require('dgram');

var client = dgram.createSocket('udp4');

client.send('Test Message', 0, 12, PORT, HOST, function(err, bytes) {
    if (err) throw err;
    console.log('Send: ' + HOST +':'+ PORT);
    client.close();
});

Как сделать так, чтобы он мог отправлять пакеты один за другим непрерывно?

1 Ответ

0 голосов
/ 29 января 2019

Вы закрываете сокетное соединение до завершения операций.Я могу предложить флаг, чтобы закрыть его только после того, как все сообщения были отправлены, что-то вроде: 

var totalReq = 10;
for (var i = 0; i < totalReq; i++) {
    sendMessage(i, totalReq);
}

function sendMessage(index, total) {
    client.send('Test Message', 0, 12, PORT, HOST, function(err, bytes) {
        if (err) throw err;
        console.log('Send: ' + HOST + ':' + PORT);
        // close the connection only after the last request
        if (index == total - 1) {
            client.close();
        }
    });
}
...