[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_11":-5},"routes/user.$name.topics",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20},"topics",[35,36],"user",{"_21":22,"_13":14,"_23":24,"_25":14,"_26":27,"_28":29,"_30":20,"_31":32,"_33":34},"loginname","wangjinnana","page",1,"limit",20,"total",2,"id","21980","avatar_url","https://avatars.githubusercontent.com/u/18401556?v=3","githubUsername","create_at","2016-04-11 15:46:44.409","score",25,"topic_count","reply_count",3,"is_star",false,{"_21":55,"_38":22,"_39":56,"_41":57,"_43":58,"_45":59,"_47":34,"_48":34,"_31":20,"_50":60,"_26":61,"_53":62},{"_21":37,"_38":22,"_39":40,"_41":42,"_43":44,"_45":46,"_47":34,"_48":34,"_31":49,"_50":51,"_26":52,"_53":54},"19974","author_id","tab","share","content","一直在用thrift，服务器用C++开发，想学习用node.js做客户端连接C++服务器，就安装了node.js thrift，tutorial中的例子有NodeClient.js\r\n 和NodeServer.js\r\n 其中NodeClient.js的代码\r\n var thrift = require('thrift');\r\nvar ThriftTransports = require('thrift/transport');\r\nvar ThriftProtocols = require('thrift/protocol');\r\nvar Calculator = require('./gen-nodejs/Calculator');\r\nvar ttypes = require('./gen-nodejs/tutorial_types');\r\n\r\n\r\ntransport = ThriftTransports.TBufferedTransport()\r\nprotocol = ThriftProtocols.TBinaryProtocol()\r\n\r\nvar connection = thrift.createConnection(\"localhost\", 9090, {\r\n transport : transport,\r\n protocol : protocol\r\n});\r\n\r\nconnection.on('error', function(err) {\r\n assert(false, err);\r\n});\r\n\r\n// Create a Calculator client with the connection\r\nvar client = thrift.createClient(Calculator, connection);\r\n\r\n\r\nclient.ping(function(err, response) {\r\n console.log('ping()');\r\n});\r\n\r\n\r\nclient.add(1,1, function(err, response) {\r\n console.log(\"1+1=\" + response);\r\n});\r\n\r\n\r\nwork = new ttypes.Work();\r\nwork.op = ttypes.Operation.DIVIDE;\r\nwork.num1 = 1;\r\nwork.num2 = 0;\r\n\r\nclient.calculate(1, work, function(err, message) {\r\n if (err) {\r\n console.log(\"InvalidOperation \" + err);\r\n } else {\r\n console.log('Whoa? You know how to divide by zero?');\r\n }\r\n});\r\n\r\nwork.op = ttypes.Operation.SUBTRACT;\r\nwork.num1 = 15;\r\nwork.num2 = 10;\r\n\r\nclient.calculate(1, work, function(err, message) {\r\n console.log('15-10=' + message);\r\n\r\n client.getStruct(1, function(err, message){\r\n console.log('Check log: ' + message.value);\r\n\r\n //close the connection once we're done\r\n connection.end();\r\n });\r\n});\r\nNodeServer.js可以正常运行，但是NodeClient.js运行出错，提示\r\n找不到thrift/transport\r\n![捕获.PNG](//static.cnodejs.org/FkFByblooRHDZrqCzMpMlTlrQWnB)\r\n\r\n其实查看thrift目录下的源码，可以看到index.js里面已经导出了transport，所以可以直接使用导出的thrift，\r\n修改代码为\r\nvar thrift = require('thrift');\r\nvar Calculator = require('./gen-nodejs/Calculator');\r\nvar ttypes = require('./gen-nodejs/tutorial_types');\r\n\r\n\r\ntransport = thrift.TBufferedTransport\r\nprotocol = thrift.TBinaryProtocol\r\n\r\nvar connection = thrift.createConnection(\"localhost\", 9090, {\r\n transport : transport,\r\n protocol : protocol\r\n});\r\n\r\nconnection.on('error', function(err) {\r\n assert(false, err);\r\n});\r\n\r\n// Create a Calculator client with the connection\r\nvar client = thrift.createClient(Calculator, connection);\r\n\r\n\r\nclient.ping(function(err, response) {\r\n console.log('ping()');\r\n});\r\n\r\n\r\nclient.add(1,1, function(err, response) {\r\n console.log(\"1+1=\" + response);\r\n});\r\n\r\n\r\nwork = new ttypes.Work();\r\nwork.op = ttypes.Operation.DIVIDE;\r\nwork.num1 = 1;\r\nwork.num2 = 0;\r\n\r\nclient.calculate(1, work, function(err, message) {\r\n if (err) {\r\n console.log(\"InvalidOperation \" + err);\r\n } else {\r\n console.log('Whoa? You know how to divide by zero?');\r\n }\r\n});\r\n\r\nwork.op = ttypes.Operation.SUBTRACT;\r\nwork.num1 = 15;\r\nwork.num2 = 10;\r\n\r\nclient.calculate(1, work, function(err, message) {\r\n console.log('15-10=' + message);\r\n\r\n client.getStruct(1, function(err, message){\r\n console.log('Check log: ' + message.key + message.value);\r\n\r\n //close the connection once we're done\r\n connection.end();\r\n });\r\n});\r\n此时可以正常运行，\r\n\r\n示例代码中的一些问题\r\nvar thrift = require('thrift');\r\nvar ThriftTransports = require('thrift/transport');\r\nvar ThriftProtocols = require('thrift/protocol');\r\nvar Calculator = require('./gen-nodejs/Calculator');\r\nvar ttypes = require('./gen-nodejs/tutorial_types');\r\n\r\n\r\ntransport = ThriftTransports.TBufferedTransport()\r\nprotocol = ThriftProtocols.TBinaryProtocol()\r\n\r\ntransport 应为Thriftransports.TBufferedTransport和thrift.TBufferedTransport等效\r\nprotocol 应为ThriftProtocols.TBinaryProtocol和thrift.TBinaryProtocol等效\r\n不需要括号调用\r\nvar connection = thrift.createConnection(\"localhost\", 9090, {\r\n transport : transport,\r\n protocol : protocol\r\n});\r\nconnection最后的选项如果没有的话默认是transport为buffer，protocol为binary\r\n如果服务器为TFramedTransport，选项要传递{transport:thrift.TFramedTransport}\r\n\r\nnode.js 与C++通信的一个demo\r\n\r\n协议文件\r\nadd.thrift\r\nstruct AddReq {\r\n 1: i32 x;\r\n 2: i32 y;\r\n 3: i32 p;\r\n}\r\n\r\nstruct AddResp {\r\n 1: i32 z;\r\n}\r\n\r\nservice AddServer {\r\n AddResp Add(1: AddReq req);\r\n}\r\n服务器\r\n#include \r\n#include \r\n#include \r\n#include \r\n#include \r\n#include \r\n#include \r\n#include \r\n#include \"thrift_test/protocol/AddServer.h\"\r\n\r\nusing ::apache::thrift::TProcessor;\r\nusing ::apache::thrift::concurrency::ThreadManager;\r\nusing ::apache::thrift::concurrency::PosixThreadFactory;\r\nusing ::apache::thrift::transport::TProtocolFactory;\r\nusing ::apache::thrift::protocol::TBinaryProtocolFactory;\r\nusing ::apache::thrift::server::TNonblockingServer;\r\nusing namespace std;\r\nusing ::boost::shared_ptr;\r\n\r\nclass AddServer: public AddServerIf {\r\n public:\r\n\tvirtual void Add(AddResp& _return, const AddReq& req) {\r\n\t\tcout<<\"set p\"< handler(new AddServer());\r\n shared_ptr processor(new AddServerProcessor(handler));\r\n shared_ptr protocolFactory(new TBinaryProtocolFactory());\r\n\r\n shared_ptr threadManager =\r\n ThreadManager::newSimpleThreadManager(32);\r\n shared_ptr threadFactory =\r\n shared_ptr(new PosixThreadFactory());\r\n threadManager->threadFactory(threadFactory);\r\n threadManager->start();\r\n TNonblockingServer server(\r\n processor, protocolFactory, 9876, threadManager);\r\n server.serve();\r\n } catch (const std::exception& e) {\r\n std::cerr << \"exception: \" << e.what() << \"\\n\";\r\n }\r\n}\r\nnode.js客户端\r\nvar thrift = require('thrift');\r\nvar AddServer = require('./gen-nodejs/AddServer');\r\nvar ttypes = require('./gen-nodejs/add_types');\r\nvar assert= require('assert');\r\n\r\nvar connection = thrift.createConnection(\"localhost\", 9876,\r\n{transport:thrift.TFramedTransport});\r\n\r\nconnection.on('error', function(err) {\r\n //console.log(\"connect error\");\r\n throw new Error(\"connection error\");\r\n //assert(false, err);\r\n});\r\n\r\nvar client = thrift.createClient(AddServer, connection);\r\n\r\ntry {\r\n\treq= new ttypes.AddReq({x:1,y:2,p:3});\r\n\tconsole.log(req.x);\r\n\tconsole.log(req.y);\r\n\tconsole.log(req.p);\r\n\tclient.Add(req,function(err, resp) {\r\n\tconsole.log(resp.z);\r\n\tconnection.end();\r\n\t});\r\n} catch(e) {\r\n console.log(e);\r\n console.log(\"bye\");\r\n};","title","node.js thrift","last_reply_at","2016-08-30 15:40:57.488","good","top",6,"visit_count",5475,"2016-08-28 15:18:20.965","author",{"_13":14,"_23":24},"20016","ask","刚安装了ws，试着库中的例子发现连接不了，也不报错，有没有人遇到过这个问题，怎么解决的\r\n浏览器为chrome\r\nvar WebSocketServer = require('../node_modules/ws').Server\r\n , http = require('http')\r\n , express = require('express')\r\n , //app = express.createServer();\r\n app = express();\r\n\r\napp.use(express.static(__dirname + '/public'));\r\napp.listen(8080);\r\n\r\nvar wss = new WebSocketServer({server: app});\r\nwss.on('connection', function(ws) {\r\n var id = setInterval(function() {\r\n ws.send(JSON.stringify(process.memoryUsage()), function() { /* ignore errors */ });\r\n }, 100);\r\n console.log('started client interval');\r\n ws.on('close', function() {\r\n console.log('stopping client interval');\r\n clearInterval(id);\r\n });\r\n});\r\n\r\nindex.html\r\n\r\n\r\n \r\n \r\n \r\n \r\n \r\n Server Stats
\r\n RSS:

\r\n Heap total:

\r\n Heap used:

\r\n\t\r\n \r\n","websocket 连不上","2016-08-31 07:17:16",5932,"2016-08-30 14:41:38.248",{"_13":14,"_23":24}]