Skip to content

Instantly share code, notes, and snippets.

@johnnyeric

johnnyeric/tcp-socketio-sample.js

Forked from maripiyoko/tcp-socketio-sample.js
Created February 9, 2017 22:37
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save johnnyeric/173bf2d2eba7d3f9f1fea626b43ebbfb to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save johnnyeric/173bf2d2eba7d3f9f1fea626b43ebbfb to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @maripiyoko maripiyoko revised this gist Nov 29, 2014. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion tcp-socketio-sample.js
    View file
    Original file line number Diff line number Diff line change
    @@ -39,7 +39,7 @@ net.createServer(function (socket) {
    var line = data.toString();
    console.log('got "data"', line);
    socket.pipe(writable);
    io.sockets.emit('emit_from_server', line);
    io.sockets.emit('emit_from_server', line); // socket.io呼び出し
    });
    socket.on('end', function() {
    console.log('end');
  2. @maripiyoko maripiyoko created this gist Nov 29, 2014.
    56 changes: 56 additions & 0 deletions tcp-socketio-sample.js
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,56 @@
    // socket io
    var app = require('http').createServer(handler),
    io = require('socket.io').listen(app),
    fs = require('fs');

    app.listen(3000, function() {
    console.log('Socket IO Server is listening on port 3000');
    });

    function handler(req, res) {
    fs.readFile(__dirname + '/index.html', function(err, data) {
    if(err) {
    res.writeHead(500);
    return res.end('Error');
    }
    res.writeHead(200);
    res.write(data);
    res.end();
    })
    };

    // 待ち受け
    io.sockets.on('connection', function(socket) {
    console.log('connection...');
    socket.on('emit_from_client', function(data) {
    console.log('socket.io server received : '+data);
    // 接続しているソケット全部
    io.sockets.emit('emit_from_server', data);
    });
    });

    // TCP server
    var net = require('net');
    var writable = require('fs').createWriteStream('test.txt');

    net.createServer(function (socket) {
    console.log('socket connected');
    socket.on('data', function(data) {
    var line = data.toString();
    console.log('got "data"', line);
    socket.pipe(writable);
    io.sockets.emit('emit_from_server', line);
    });
    socket.on('end', function() {
    console.log('end');
    });
    socket.on('close', function() {
    console.log('close');
    });
    socket.on('error', function(e) {
    console.log('error ', e);
    });
    socket.write('hello from tcp server');
    }).listen(3080, function() {
    console.log('TCP Server is listening on port 3080');
    });