ruur/egg-udp

udp plugin for egg.

egg-udp

udp plugin for egg.

Install

$ npm i egg-udp --save

Usage

// {app_root}/config/plugin.js
exports.udp = {
  enable: true,
  package: 'egg-udp',
};

Configuration

// {app_root}/config/config.default.js
exports.udp = {
  port: 5000,
};

see config/config.default.js for more detail.

Example

Router example

// {app_root}/app/router.ts(or router.js)
app.udp.handle('proxy.handle');

Controller example

• This is the example for javascript.

  // {app_root}/app/udp/controller/proxy.js
  module.exports = app => {
    return {
      async handle(udp) {
        udp.on('error', (err) => {
          console.log(`udp error:\n${err.stack}`);
        });
  
        udp.on('message', (msg, rinfo) => {
          console.log(`udp server got: ${msg.toString()} from ${rinfo.address}:${rinfo.port}`);
        });
  
        udp.on('listening', () => {
          const address = udp.address();
          console.log(`udp listening ${address.address}:${address.port}`);
        });
      },
    };
  };

• This is the example for typescript.

  // {app_root}/app/udp/controller/proxy.ts
  import {  Application } from 'egg';
  import { Socket } from 'dgram';
  
  interface Rinfo {
    address: string,
    family: string,
    port: number,
    size: number,
  }
  
  export default (app: Application) => {
    return {
      async handle(udp: Socket) {
        udp.on('error', (err) => {
          console.log(`udp error:\n${err.stack}`);
        });
  
        udp.on('message', (msg, rinfo: Rinfo) => {
          console.log(`udp server got: ${msg.toString()} from ${rinfo.address}:${rinfo.port}`);
        });
  
        udp.on('listening', () => {
          const address = udp.address();
          console.log(`udp listening ${address.address}:${address.port}`);
        });
      },
    };
  };

Test

// Test udp server by Linux
$ echo "2019-05-20T15:30:57 testlog" | nc -u -w1 127.0.0.1 5000
// Check it in server log
udp server got: 2019-05-20T15:30:57 testlog from 127.0.0.1:5000

License

MIT

egg-udp's Issues

无法连接，启动报错

完全按照文档书写，但是程序启动后会报错，uDP没有连接成功
{ Error: write ENOTSUP
at ChildProcess.target._send (internal/child_process.js:741:20)
at ChildProcess.target.send (internal/child_process.js:625:19)
at sendHelper (internal/cluster/utils.js:25:15)
at send (internal/cluster/master.js:356:10)
at handle.add (internal/cluster/master.js:328:5)
at SharedHandle.add (internal/cluster/shared_handle.js:29:3)
at queryServer (internal/cluster/master.js:317:10)
at Worker.onmessage (internal/cluster/master.js:253:5)
at ChildProcess.onInternalMessage (internal/cluster/utils.js:42:8)
at ChildProcess.emit (events.js:187:15) errno: 'ENOTSUP', code: 'ENOTSUP', syscall: 'write' }
不知道是什么原因造成的，另外我不适用本插件，自己写udp连接，程序启动后调用方法启动udp连接也会报这个错误。