socket.io emit的几种用法解释
socket.io emit的几种用法解释
服务器信息传输
socket.emit('message', &this is a test&);
socket.broadcast.emit('message', &this is a test&);
socket.broadcast.to('game').emit('message', 'nice game');
io.sockets.emit('message', &this is a test&);
io.sockets.in('game').emit('message', 'cool game');
io.sockets.socket(socketid).emit('message', 'for your eyes only');
上述集中方式为socket.io常用的数据传输方式,
io.sockets.on('connection', function (socket) {
回调函数的socket参数为一个&client&与服务器的连接标示，不同的&client&会有不同的连接标示。
不分组，数据传输
socket.emit&
socket.emit&信息传输对象为当前&socket&对应的&client&，各个client
socket&相互不影响。
socket.broadcast.emit&
socket.broadcast.emit&信息传输对象为所有&client&，排除当前socket&对应的&client&。
io.sockets.emit&
信息传输对象为所有&client&。
分组数据传输
类似于之前提过的&of&方法生成命名空间来管理用户，&socket.io&可以使用分组方法,&socket.join()&,以及与之对应的&socket.leave()&。
io.sockets.on('connection', function (socket) {
socket.on('firefox', function (data) {
socket.join('firefox');
socket.on('chrome',function(data){
socket.join('chrome');
假设有两个聊天室，一个名为firefox，另一个为chrome，客户端操作
socket.emit('firefox')&，就可以加入&firefox&聊天室；&
socket.emit('chrome')&，就可以加入&chrome&聊天室；
向一个分组传输消息，有两种方式：
socket.broadcast.to('chrome').emit('event_name', data);
io.sockets.in('chrome').emit('event_name', data)
broadcast&方法允许当前&socket
client&不在该分组内。
可能有一个疑问，一个&socket&是否可以同时存在于几个分组，等效于一个用户会同时在几个聊天室活跃，答案是”可以“，&socket.join()&添加进去就可以了。官方提供了订阅模式的示例：
socket.on('subscribe', function(data) {
socket.join(data.room); })
socket.on('unsubscribe', function(data) {
socket.leave(data.room);
后台处理订阅/退订事件
socket = io.connect('http://127.0.0.1:1338/'); socket.emit('subscribe',{&room& : &chrome&}; socket.emit('unsubscribe',{&room& : &chrome&};
前端触发订阅/退订事件，就可以加入对应的聊天室。 通过&of&方法也可以通过划分命名空间的方式，实现聊天室功能，但不如分组管理来的方便。
Socket.io难点大放送（暂时没有搞定）
socket&连接需要添加权限验证，让已登录的用户&socket&连接到服务器，未登录的用户无条件拒绝。全局授权管理如下：
io.sockets.authorization(function (handshakeData, callback) {
callback(null, true); }).
callback&函数有两个参数，第一个为&error&,第二个参数为是否授权bool值，通过授权回调函数应为&callback(null,true)&,其它情况下都为拒绝建立连接。
按照web的开发方式，检测是否登录首选&cookie-session&来实现，问题也是出在这里。&websocket&握手阶段属于&HTTP&协议，简单来说是可以读到cookie，就可以实现session。&
+ 精准单用户推送&
理论上来说
io.sockets.socket(socketid).emit('message', 'for your eyes only');
就可以向一个特定用户推送消息，但是如何获得这个&socketId&，就是生成一个哈希数组，key为username，值为socket.id，这样就可以通过用户名获取对应的id，进而可以向特定client推送消息。
感谢关注 Ithao123精品文库频道，是专门为互联网人打造的学习交流平台，全面满足互联网人工作与学习需求，更多互联网资讯尽在 IThao123!
Laravel是一套简洁、优雅的PHP Web开发框架(PHP Web Framework)。它可以让你从面条一样杂乱的代码中解脱出来；它可以帮你构建一个完美的网络APP，而且每行代码都可以简洁、富于表达力。
Hadoop是一个由Apache基金会所开发的分布式系统基础架构。
用户可以在不了解分布式底层细节的情况下，开发分布式程序。充分利用集群的威力进行高速运算和存储。
Hadoop实现了一个分布式文件系统（Hadoop Distributed File System），简称HDFS。HDFS有高容错性的特点，并且设计用来部署在低廉的（low-cost）硬件上；而且它提供高吞吐量（high throughput）来访问应用程序的数据，适合那些有着超大数据集（large data set）的应用程序。HDFS放宽了（relax）POSIX的要求，可以以流的形式访问（streaming access）文件系统中的数据。
Hadoop的框架最核心的设计就是：HDFS和MapReduce。HDFS为海量的数据提供了存储，则MapReduce为海量的数据提供了计算。
产品设计是互联网产品经理的核心能力，一个好的产品经理一定在产品设计方面有扎实的功底，本专题将从互联网产品设计的几个方面谈谈产品设计
随着国内互联网的发展，产品经理岗位需求大幅增加，在国内，从事产品工作的大部分岗位为产品经理，其实现实中，很多从事产品工作的岗位是不能称为产品经理，主要原因是对产品经理的职责不明确，那产品经理的职责有哪些，本专题将详细介绍产品经理的主要职责
IThao123周刊socket.io，系统api， - 神奇的旋风 - 博客园
随笔 - 674, 文章 - 0, 评论 - 7, 引用 - 0
io.on('connection',function(socket));
监听客户端连接,回调函数会传递本次连接的socket
io.sockets.emit('String',data);
给所有客户端广播消息
io.sockets.socket(socketid).emit('String', data);
给指定的客户端发送消息
socket.on('String',function(data));
监听客户端发送的信息
socket.emit('String', data);
给该socket的客户端发送消息
//给除了自己以外的客户端广播消息
socket.broadcast.emit("msg",{data:"hello,everyone"});
//给所有客户端广播消息
io.sockets.emit("msg",{data:"hello,all"});
socket.on('group1', function (data) {
socket.join('group1');
socket.on('group2',function(data){
socket.join('group2');
客户端发送
socket.emit('group1')，就可以加入group1分组；socket.emit('group2')，就可以加入group2分组；
一个客户端可以存在多个分组（订阅模式）
socket.leave(data.room);
对分组中的用户发送信息
//不包括自己
socket.broadcast.to('group1').emit('event_name', data);
//包括自己
io.sockets.in('group1').emit('event_name', data);
broadcast方法允许当前socket client不在该分组内
获取连接的客户端socket&
io.sockets.clients().forEach(function (socket) {
获取分组信息
//获取所有房间（分组）信息
io.sockets.manager.rooms
//来获取此socketid进入的房间信息
io.sockets.manager.roomClients[socket.id]
//获取particular room中的客户端，返回所有在此房间的socket实例
io.sockets.clients('particular room')
另一种分组方式
io.of('/some').on('connection', function (socket) {
socket.on('test', function (data) {
socket.broadcast.emit('event_name',{});
var socket = io.connect('ws://103.31.201.154:5555/some')
socket.on('even_name',function(data){
console.log(data);
客户端都链接到ws://103.31.201.154:5555&但是服务端可以通过io.of('/some')将其过滤出来。
另外，Socket.IO提供了4个配置的API：io.configure, io.set, io.enable, io.disable。其中io.set对单项进行设置，io.enable和io.disable用于单项设置布尔型的配置。io.configure可以让你对不同的生产环境（如devlopment，test等等）配置不同的参数。
建立一个socket连接
var socket = io("ws://103.31.201.154:5555");
监听服务消息
socket.on('msg',function(data){
socket.emit('msg', {rp:"fine,thank you"}); //向服务器发送消息
console.log(data);
socket.on("String",function(data)) 监听服务端发送的消息 Sting参数与服务端emit第一个参数相同
监听socket断开与重连。
socket.on('disconnect', function() {
console.log("与服务其断开");
socket.on('reconnect', function() {
console.log("重新连接到服务器");
客户端socket.on()监听的事件：
connect：连接成功connecting：正在连接disconnect：断开连接connect_failed：连接失败error：错误发生，并且无法被其他事件类型所处理message：同服务器端message事件anything：同服务器端anything事件reconnect_failed：重连失败reconnect：成功重连reconnecting：正在重连当第一次连接时，事件触发顺序为：connecting-&connect；当失去连接时，事件触发顺序为：disconnect-&reconnecting（可能进行多次）-&connecting-&reconnect-&connect。
from：/xiezhengcai/p/3956401.html}