[{"_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":16},"topics",[35],"user",{"_20":21,"_13":14,"_22":23,"_24":25,"_26":27,"_28":29,"_30":16,"_31":32,"_33":34},"loginname","mallon","page",1,"limit",20,"total","id","522","avatar_url","http://www.gravatar.com/avatar/9b7286baa540855020250fe294ff3b81?s=48","githubUsername","","create_at","2011-08-31 16:36:55","score",5,"topic_count","reply_count",0,"is_star",false,{"_20":36,"_37":21,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":34,"_46":34,"_31":16,"_47":48,"_26":49,"_50":51},"160","author_id","tab","content","

简介\nJson Messaging是使用node.js技术构建的发布/订阅类型的消息服务器，具有如下特性：\n1、支持TCP和WebSocket协议；\n2、传输帧使用Json格式；\n3、可以使用正则表达式订阅消息目的地，正则表达式中可以包含“捕获”，所有目的地匹配该正则表达式的消息，连同目的地的“捕获”都将发送到订阅方；\n4、一个客户端可以订阅多个消息目的地；\n5、为了简化设计，服务器端不持久化消息。\n项目\nhttps://sourceforge.net/projects/jsonmessaging/\n下载\nhttps://sourceforge.net/projects/jsonmessaging/files/\n致谢\nJson Messaging消息服务器使用了很多第三方的框架和技术，感谢他们辛勤的工作。\nJson：http://www.json.org\nnode.js：http://nodejs.org\nnode-uuid：https://github.com/broofa/node-uuid\nWebSocket-Node：https://github.com/Worlize/WebSocket-Node\n使用方法\n1、编译安装node.js；\n2、打开server/config.js，可以配置TCP和WebSocket端口；\n3、启动消息服务器：node server/server.js。\n例子\n使用最新版本的Firefox或者Chrome打开下面的HTML文件可以发送和接收消息。\n\n\n\n\n Json Messaging Example\n\n div#output {\n border: 1px solid #000;\n width: 960px;\n height: 450px;\n overflow: auto;\n background-color: #333;\n color: #6cf;\n }

\n\n

    strong {\n        color: #f66;\n    }\n\n    input#input {\n        border: 1px solid #000;\n        width: 640px;\n    }\n\n    button {\n        border: 1px solid #000;\n        width: 100px;\n    }\n</style>\n<script>\n    // connect to the Json Messaging server and return an 'connection' object\n    function connect(host, port, messageListener, errorListener) {\n        window.WebSocket = window.WebSocket || window.MozWebSocket;\n\n        if (!window.WebSocket) {\n            alert('Your browser does not support WebSocket.');\n            return null;\n        }\n\n        var connection = new WebSocket('ws://' + host + ':' + port);\n\n        connection.onmessage = function(message) {\n            try {\n                var parsed = JSON.parse(message.data);\n                switch (parsed.type) {\n                    case 'message':\n                        if (messageListener) {\n                            messageListener(parsed.content, parsed.match);\n                        }\n                        break;\n                    case 'error':\n                        if (errorListener) {\n                            errorListener(parsed.content);\n                        }\n                        break;\n                    default:\n                        throw new Error('Unknown message type ' + parsed.type);\n                        break;\n                }\n            } catch (e) {\n                console.warn(e);\n                alert(e);\n            }\n        };\n\n        connection.publish = function(content, destination) {\n            connection.send(JSON.stringify({\n                type: 'publish',\n                destination: destination,\n                content: content\n            }));\n        };\n\n        connection.subscribe = function(destination) {\n            connection.send(JSON.stringify({\n                type: 'subscribe',\n                destination: destination\n            }));\n        };\n\n        connection.unsubscribe = function(destination) {\n            connection.send(JSON.stringify({\n                type: 'unsubscribe',\n                destination: destination\n            }));\n        };\n\n        return connection;\n    }\n\n    // the 'connection' object\n    var connection = null;\n\n    var output = null;\n\n    var input = null;\n\n    // initialize\n    window.onload = function() {\n        output = document.getElementById('output');\n        input = document.getElementById('input');\n\n        // connect to the local server\n        connection = connect(\n                'localhost',\n                8155,\n                // message handler\n                function(content, match) {\n                    output.innerHTML += ('<strong>Message: </strong>' + content + '<br>\\n');\n                },\n                // error handler\n                function(content) {\n                    output.innerHTML += ('<strong>Error: </strong>' + content + '<br>\\n');\n                }\n        );\n\n        // subscribe a topic\n        connection.onopen = function() {\n            connection.subscribe('test');\n        };\n    };\n\n    function _send() {\n        connection.publish(input.value, 'test');\n    }\n\n    function _clear() {\n        output.innerHTML = '';\n    }\n</script>\n

\n\n

\nSend\nClear\n\n\n下面的C程序发送三条HelloWorld消息，第一条是英文，第二条是中文，第三条是Unicode转义的中文。注意源代码必须以UTF-8编码保存。

\n\n

include

\n\n

include

\n\n

include

\n\n

include

\n\n

include

\n\n

include

\n\n

include

\n\n

include

\n\n

int main(int argc, char ** argv)\n{\n int fd;\n struct sockaddrin addr;\n int ret;\n const char publishframe1[] =\n \"{\\\"type\\\":\\\"publish\\\",\\\"destination\\\":\\\"test\\\",\\\"content\\\":\\\"Hello World\\\"}\";\n const char publishframe2[] =\n \"{\\\"type\\\":\\\"publish\\\",\\\"destination\\\":\\\"test\\\",\\\"content\\\":\\\"你好世界\\\"}\";\n const char publishframe_3[] =\n \"{\\\"type\\\":\\\"publish\\\",\\\"destination\\\":\\\"test\\\",\\\"content\\\":\\\"\\u4f60\\u597d\\u4e16\\u754c\\\"}\";

\n\n

fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);\n\nmemset(&addr, 0, sizeof(addr));\naddr.sin_family = AF_INET;\naddr.sin_addr.s_addr = inet_addr(\"127.0.0.1\");\naddr.sin_port = htons(8153);\n\nret = connect(fd, (struct sockaddr *)&addr, sizeof(addr));\nprintf(\"%d\\n\", ret);\n\nret = write(fd, publish_frame_1, sizeof(publish_frame_1));\nprintf(\"%d\\n\", ret);\n\nret = write(fd, publish_frame_2, sizeof(publish_frame_2));\nprintf(\"%d\\n\", ret);\n\nret = write(fd, publish_frame_3, sizeof(publish_frame_3));\nprintf(\"%d\\n\", ret);\n

\n\n

}\n帧格式\n消息服务器的应用层数据帧采用Json格式，使用UTF-8编码的纯文本，在TCP协议中，使用'\\0'作为帧间分隔，在WebSocket协议中遵循WebSocket草案标准。\n帧格式有5类，其中，客户端到服务器端的3类，服务器端到客户端的2类。\n客户端到服务器端\n发布帧\n客户端发送一条消息到服务器的目的地中，所有连接到服务器并且订阅了该目的地（正则表达式匹配）的客户端都能接收到该消息。\n帧格式为：\n{\n \"type\": \"publish\",\n \"destination\": <消息目的地>,\n \"content\": <消息内容>\n}\n其中，消息目的地为字符串类型；消息内容同样也必须是Json格式的。\n订阅帧\n客户端订阅服务器的一个目的地，所有匹配该目的地的消息都会发送到该客户端。\n帧格式为：\n{\n \"type\": \"subscribe\",\n \"destination\": <消息目的地>\n}\n其中，消息目的地可以是正则表达式，且正则表达式中可以含有“捕获”，服务器会使用该正则表达式匹配发送的消息目的地，如果符合，则会把该消息连同匹配结果一并发给客户端，在下面的“消息帧”介绍中有具体的例子。\n同一个客户端可以订阅多个目的地。\n取消订阅帧\n客户端取消订阅服务器的一个目的地。\n帧格式为：\n{\n \"type\": \"subscribe\",\n \"destination\": <消息目的地>\n}\n其中，消息目的地等于订阅帧中的消息目的地。\n当客户端断开连接后，服务器端会自动取消该客户端的所有订阅。\n服务器端到客户端\n消息帧\n一旦消息目的地匹配，服务器端会把匹配结果连同消息内容发给客户端。\n帧格式为：\n{\n \"type\": \"message\",\n \"match\": <匹配结果>,\n \"content\": <消息内容>\n}\n匹配结果为一个数组，至少包含一个元素，即订阅的消息目的地；如果订阅的消息目的地是正则表达式且其中含有“捕获”，那么从第二往后的元素为捕获结果，参考JavaScript 正则表达式规范。\n举例：\n假设设备的网口状态信息在消息服务中发布，规定目的地格式为：“/devices/<设备名>/<网口名>”；消息内容为：“down”表示停止、“up”表示启动。\n下面两个发布帧，表示设备a的第1个网口停止了，而设备b的第0个网口启动了：\n{\"type\":\"publish\",\"destination\":\"/devices/a/if1\",\"content\":\"down\"}\n{\"type\":\"publish\",\"destination\":\"/devices/b/if0\",\"content\":\"up\"}\n如果客户端订阅目的地为“/devices/.”，那么它将能收到所有设备的所有网口的状态消息，接收到的消息帧如下：\n{\"type\":\"message\",\"match\":[\"/devices/a/if1\"],\"content\":\"down\"}\n{\"type\":\"message\",\"match\":[\"/devices/b/if0\"],\"content\":\"up\"}\n如果想在程序中更方便地对设备和网口做分类处理，可以把订阅目的地改为“/devices/(.)/(.*)”，其中小括号即为“捕获”。\n接收到的消息帧会变为：\n{\"type\":\"message\",\"match\":[\"/devices/a/if1\",\"a\",\"if1\"],\"content\":\"down\"}\n{\"type\":\"message\",\"match\":[\"/devices/b/if0\",\"b\",\"if0\"],\"content\":\"up\"}\n可以看到，match中增加了捕获的结果。\n错误帧\n如果服务器端产生错误，例如客户端发送的帧超长、非Json格式等，将会向客户端返回错误帧。\n帧格式为：\n{\n \"type\": \"error\",\n \"content\": <错误内容>\n}\n客户端可以对错误进行相应的处理。\n源代码结构\nserver.js\n程序入口。\nconfig.js\n全局配置，其中的udpPort并没有使用，因为UDP难以知晓客户端状态，所以不打算实现UDP协议。\nlog.js\n控制台日志，相比其它第三方的日志模块的特点是使用简单，而且能够输出日志产生的源代码的位置，便于调试。\nprotocol.js\n协议帧的包装。\nexchange.js\n负责处理发布和订阅的消息，是服务器代码的核心部分。\ntcp.js\nTCP协议的实现。\nws.js\nWebSocket协议的实现。

","title","发布一个node.js编写的消息服务器，支持最新的websocket草案","last_reply_at","2012-02-08 14:41:15.828","good","top","visit_count",8519,"2012-01-20 06:17:27.365","author",{"_13":14,"_22":23}]