reactive_socket_service_base          execution_context_service_base <reative_socket_service<Porotocol>>  

                                                                \                         |

                                                                reactive_socket_service<Protocol>

                                                                                    |                                                                          

                                  socket_basic             io_object_impl<Protocol, Executor>  (成员变量)               system_executor            

                                                              \                   |                                                                                      |

                                                                   basic_socket<Protocol, Executor>    其中 Exector =====>     executor 

                                                                         /                         \                                                                       

                          basic_stream_socket<tcp>                 basic_datagram_socket<udp>                        

socket_basic:定义socket共用的一些数据类型和选项

using System;
using WebSocketSharp;


namespace WebsocketTest
{
    class Program
    {
        public static void Main(string[] args)
        {
            try
            { 
            using (var ws = new WebSocketSharp.WebSocket("ws://192.168.18.186:7884"))
            {
               Console.WriteLine("started");
                ws.Connect();
                ws.Send("START");
                Console.ReadLine();
                }
            }catch(Exception ex)
            {
                Console.WriteLine(ex.Message);
                Console.ReadLine();
            }

        }
    }
}

09-05-2017 16:20:41|Fatal|WebSocket.connect:0|System.Net.sockets.socketException (0x80004005): No connection Could be made because the target machine actively refused it 192.168.18.186:7884
                             at System.Net.sockets.TcpClient..ctor(String hostname,Int32 port)
                             at WebSocketSharp.WebSocket.setClientStream()
                             at WebSocketSharp.WebSocket.doHandshake()
                             at WebSocketSharp.WebSocket.connect()

解决方法

import datetime
import json
from flask_socketio import Namespace, emit, SocketIO, disconnect
from flask import Flask, render_template,request

app = Flask(__name__)
socketio = SocketIO(app,cors_allowed_origins="*")

class MyCustomNamespace(Namespace):

    def __init__(self,namespace):
        super(MyCustomNamespace, self).__init__(namespace)
        self.sid = None
    def on_connect(self):
        self.sid = request.sid
        print(''建立连接成功！-{}''.format(self.sid))

    def on_disconnect(self):
        print(''客户端断开连接！'')

    def close_room(self, room):
        socketio.close_room(room=self.sid)
        print(''{}-断开连接''.format(self.sid))

    def on_my_event(self, data):
        while True:
            print(data)
            socketio.sleep(5)
            current_date = str(datetime.datetime.now())
            dic = {''current_date'': current_date}
            res_json = json.dumps(dic)
            emit(''server_response'', res_json)


socketio.on_namespace(MyCustomNamespace(''/test''))

if __name__ == ''__main__'':
    socketio.run(app)

我正在尝试将数据流式传输到浏览器。但是，我正在努力将其连接到浏览器。这是我的html：

<ul></ul>
<script src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.1/jquery.min.js"></script>
<script src="/socket.io/socket.io.js"></script>
<script>
    var socket = io.connect();
    jQuery(function ($) {
        var tweetList = $('ul.tweets');
        socket.on('tweet',function (data) {
            tweetList .prepend('<li>' + data.user + ': ' + data.text + '</li>'); 
        }); 
    });
</script>

这是我的app.js的相关部分：

var express = require('express'),twitter = require('ntwitter'),http = require('http'),path = require('path');

var app = express();

var io = require('socket.io').listen(app);

app.get('/',function (req,res) { res.sendfile(__dirname + '/index.html'); });

app.listen(app.get('port'),function(){
   console.log("Express server listening on port " + app.get('port'));
});

io.sockets.volatile.emit('tweets',{
            user: data.user.screen_name,text: data.text,geo : geo,latitude: latitude,longitude: longitude
                });

我通过packages.json文件安装了socket.io 0.9.16：

"dependencies": {
    "express": "3.2.6","jade": "*","ntwitter":"0.2.10","socket.io":"0.9.x"
  }

有谁可以帮我离开这里吗？为什么找不到文件？

深入挖掘。为了测试套接字，我将其放在app.js中：

var socket = io.listen(app);

我得到错误：

TypeError: Object #<Manager> has no method 'listen'
    at Object.<anonymous> (/home/andy/dev/node/mytwittermap/app.js:49:17)
    at Module._compile (module.js:456:26)
    at Object.Module._extensions..js (module.js:474:10)
    at Module.load (module.js:356:32)
    at Function.Module._load (module.js:312:12)
    at Function.Module.runMain (module.js:497:10)
    at startup (node.js:119:16)
    at node.js:901:3