本文目录
nodejs socket怎么主动刷新缓存区数据
清空socket缓存区的数据的方法由于socket是以数据流的形式发送数据，接收方不知道对方一次性发送了多少数据，也能保证对方一次性发送的数据能在同一刻接收到，所以Receive方法是这么工作的：接受一个byye类型的参数作为缓冲区，在经过一定的时间后把接收到的数据填充到这个缓冲区里面，并且返回实际接收到数据的长度，这个实际接收到的数据长度有可能为0（没有接收到数据）、大于0小于缓冲区的长度（接收到数据，但是没有我们预期的多）、等于缓冲区的长度（说明接收到的数据大于等于我们预期的长度）。每次接收缓冲区都用同一个byte byteMessage，并且你没有检查接收到的数据长度，所以第一次你接收到的数据是123456，第二次你只接收到了8，但是缓冲区里面还有23456，所以加起来就是823456了。socket接收缓冲区的大小有讲究，设置大了接收起来慢，因为它要等尽可能多的数据接收到了再返回；设置小了需要重复多次调用接收方法才能把数据接收完，socket有个属性，标识了系统默认的接收缓冲区大小，可以参考这个！ 还有就是用recv读取，但是由于不知道缓存里有多少数据，如果是阻塞模式，到最后必然等到超时才知道数据已经读取完毕，这是个问题。 另一个是用fgetc，通过返回判断是否是feof： whlie （1） { a=fgetc（f）；if （feof（f）） break；//… b=fgetc（f）；if （feof（f）） break；//… } 当然，我不知道读取完毕后最后一次调用fgetc会不会堵塞，需要测试。 在非阻塞模式下，我们用recv就可以轻松搞定了，但是阻塞模式下，由于我们不知道缓冲区有多少数据，不能直接调用recv尝试清除。 使用一个小小的技巧，利用select函数，我们可以轻松搞定这个问题： select函数用于监视一个文件描述符集合，如果集合中的描述符没有变化，则一直阻塞在这里，直到超时时间到达；在超时时间内，一旦某个描述符触发了你所关心的事件，select立即返回，通过检索文件描述符集合处理相应事件；select函数出错则返回小于零的值，如果有事件触发，则返回触发事件的描述符个数；如果超时，返回0，即没有数据可读。 重点在于：我们可以用select的超时特性，将超时时间设置为0，通过检测select的返回值，就可以判断缓冲是否被清空。通过这个技巧，使一个阻塞的socket成了‘非阻塞’socket. 现在就可以得出解决方案了：使用select函数来监视要清空的socket描述符，并把超时时间设置为0，每次读取一个字节然后丢弃（或者按照业务需要进行处理，随你便了），一旦select返回0，说明缓冲区没数据了（“超时”了）。
nodejs 怎么把socket数据写入数据库
先说下我对socket.io的理解，websocket更像是开启了一个端口服务，来监视过往的通讯。所以我们可以依赖于当前站点80端口启socket服务，也可以放于其他端口上，比如：1 require(’socket.io’).listen(3000); 这样就是监视3000端口了，由于我用的免费服务器，没有权限打开其他端口，所以，我还是使用80了，由于80已经被express使用了，所以我只好在express使用的时候传进来了。***隐藏网址*** var socket = require(’./socket/msg’)(server); 然后 我在msg.js里是这样写的 var db = require(’../db/mysql’);var sio = require(’socket.io’);var IO = function(server) { var io = sio.listen(server)这样就和谐了，db是创建mysql连接的方法，不在本节内容里，略。在socket.io里是这样的，首先创建一个io通道的连接，然后监视里面的socket的事件，nodejs是事件驱动嘛。代码如下： io.on(’connection’, function(socket) { console.log(’a user connected.’); socket.on(’disconnect’, function() { console.log(’user disconnected.’); });})这时只要有用户连接上，就会进入connection中了，然后它的参数是个socket,如果是公聊，我们可以直接用1 io.emit(’chat message’, {});这种形式了。但我们这里是私聊，所以我们要临时的把这个socket对象保存在全局里，供与你私聊的对象使用找到你的socket,很绕口，其实这里的私聊，不算完全的点对点，它还是经过了服务器的，消息传给服务器，服务器再找到你要传达给的那个人的socket对象，发给他。这就是整个的过程了。这里我使用的是一个类数组对象来存储的. var users = {},usocket = {};socket.on(’user join’, function(data) { users = username; usocket = socket;})由于我这里需要用户名登录，所以我就把用户名作为了唯一的标识，这里用类数组的形式的好处就是我不用循环也能够很快的找到它。再我给A发送私聊时，我会先在这个uscoket里面找到它，然后调用它的emit。 function sendUserMsg(data) { if (data.to in usocket) { console.log(’================’) console.log(’to’ + data.to, data); usocket.emit(’to’ + data.to, data); usocket.emit(’to’ + data.user, data); console.log(’================’) }}这里我emit了两次的原因是，我发给对方消息的同时，我自己也要收到这个消息，然后把它显示出来，为什么这样？其一，接口统一了，聊天里的内容全是服务器过来的，其二，证明我发送成功了。然后我在客户端监听时，也用我自己的用户名起了一个to+用户名的事件监听。socket.on(’to’ + user, function(data) { //console.log(data); formatMsg(data);})这样，不管是我发的消息，还是我收到消息，都会进入这个事件了。最后，在用户离开的时候别忘记delete掉这个对象。socket.on(’disconnect’, function() { console.log(’disconnect’) if (username) { counter--; delete users; delete usocket; if (home.name == username) { homeLeave(username); } sendmsg({ type: 0, msg: "用户《b》" + username + "《/b》离开聊天室", counter: counter, users: users }) }});
c#怎么向nodejs的socket.io发送请求
1. 简介***隐藏网址***官网非常简洁，甚至没有API文档，只有一个简单的“How to use”可以参考。因为Socket.IO就跟官网一样简洁好用易上手。那么Socket.IO到底是什么呢？Socket.IO是一个WebSocket库，包括了客户端的js和服务器端的nodejs，它的目标是构建可以在不同浏览器和移动设备上使用的实时应用。它会自动根据浏览器从WebSocket、AJAX长轮询、Iframe流等等各种方式中选择最佳的方式来实现网络实时应用，非常方便和人性化，而且支持的浏览器最低达IE5.5，应该可以满足绝大部分需求了。2. 安装部署2.1 安装首先安装非常简单，在node.js环境下只要一句：复制代码 代码如下:npm install socket.io2.2 结合express来构建服务器express是一个小巧的Node.js的Web应用框架，在构建HTTP服务器时经常使用到，所以直接以Socket.IO和express为例子来讲解。复制代码 代码如下:var express = require(’express’) , app = express()***隐藏网址*** , io = require(’socket.io’).listen(server);server.listen(3001);若不使用express，请参考socket.io/#how-to-use3. 基本使用方法主要分为服务器端和客户端两段代码，都非常简单。Server（app.js）：复制代码 代码如下://接上面的代码app.get(’/’, function (req, res) { res.sendfile(__dirname + ’/index.html’);});io.sockets.on(’connection’, function (socket) { socket.emit(’news’, { hello: ’world’ }); socket.on(’other event’, function (data) { console.log(data); });});首先io.sockets.on函数接受字符串"connection"作为客户端发起连接的事件，当连接成功后，调用带有socket参数的回调函数。我们在使用socket.IO的时候，基本上都在这个回调函数里面处理用户的请求。socket最关键的是emit和on两个函数，前者提交（发出）一个事件（事件名称用字符串表示），事件名称可以自定义，也有一些默认的事件名称，紧接着是一个对象，表示向该socket发送的内容；后者接收一个事件（事件名称用字符串表示），紧接着是收到事件调用的回调函数，其中data是收到的数据。在上面的例子中，我们发送了news事件和收到了other event事件，那么客户端应该会有对应的接收和发送事件。没错，客户端代码和服务器正好相反，而且非常相似。Client（client.js）复制代码 代码如下:《script src="/socket.io/socket.io.js"》《/script》《script》 var ***隐藏网址*** socket.on(’news’, function (data) { console.log(data); socket.emit(’other event’, { my: ’data’ }); });《/script》有两点要注意的：socket.io.js路径要写对，这个js文件实际放在了服务器端的node_modules文件夹中，在请求这个文件时会重定向，因此不要诧异服务器端不存在这个文件但为什么还能正常工作。当然，你可以把服务器端的socket.io.js这个文件拷贝到本地，使它成为客户端的js文件，这样就不用每次都向Node服务器请求这个js文件，增强稳定性。第二点是要用var socket = io.connect(’网站地址或ip’);来获取socket对象，接着就可以使用socket来收发事件。关于事件处理，上面的代码表示收到“news”事件后，打印收到的数据，并向服务器发送“other event”事件。注：内置默认的事件名例如“disconnect”表示客户端连接断开，“message”表示收到消息等等。自定义的事件名称，尽量不要跟Socket.IO中内置的默认事件名重名，以免造成不必要的麻烦。4. 其他常用API1).向所有客户端广播：socket.broadcast.emit(’broadcast message’);2).进入一个房间（非常好用！相当于一个命名空间，可以对一个特定的房间广播而不影响在其他房间或不在房间的客户端）：socket.join(’your room name’);3).向一个房间广播消息（发送者收不到消息）：socket.broadcast.to(’your room name’).emit(’broadcast room message’);4).向一个房间广播消息（包括发送者都能收到消息）（这个API属于io.sockets）：io.sockets.in(’another room name’).emit(’broadcast room message’);5).强制使用WebSocket通信：（客户端）socket.send(’hi’)，（服务器）用socket.on(’message’, function(data){})来接收。5. 使用Socket.IO构建一个聊天室最后，我们通过一个简单的实例来结束本篇。用Socket.IO构建一个聊天室就是50行左右的代码的事情，实时聊天效果也非常好。以下贴出关键代码：Server（socketChat.js）复制代码 代码如下://一个客户端连接的字典，当一个客户端连接到服务器时，//会产生一个唯一的socketId，该字典保存socketId到用户信息（昵称等）的映射var connectionList = {};exports.startChat = function (io) { io.sockets.on(’connection’, function (socket) { //客户端连接时，保存socketId和用户名 var socketId = socket.id; connectionList = { socket: socket }; //用户进入聊天室事件，向其他在线用户广播其用户名 socket.on(’join’, function (data) { socket.broadcast.emit(’broadcast_join’, data); connectionList.username = data.username; }); //用户离开聊天室事件，向其他在线用户广播其离开 socket.on(’disconnect’, function () { if (connectionList.username) { socket.broadcast.emit(’broadcast_quit’, { username: connectionList.username }); } delete connectionList; }); //用户发言事件，向其他在线用户广播其发言内容 socket.on(’say’, function (data) { socket.broadcast.emit(’broadcast_say’,{ username: connectionList.username, text: data.text }); }); })};Client(socketChatClient.js)复制代码 代码如下:var socket = ***隐藏网址***//连接服务器完毕后，马上提交一个“加入”事件，把自己的用户名告诉别人socket.emit(’join’, { username: ’Username hehe’});//收到加入聊天室广播后，显示消息socket.on(’broadcast_join’, function (data) { console.log(data.username + ’加入了聊天室’);});//收到离开聊天室广播后，显示消息socket.on(’broadcast_quit’, function(data) { console.log(data.username + ’离开了聊天室’);});//收到别人发送的消息后，显示消息socket.on(’broadcast_say’, function(data) { console.log(data.username + ’说: ’ + data.text);});//这里我们假设有一个文本框textarea和一个发送按钮.btn-send//使用jQuery绑定事件$(’.btn-send’).click(function(e) { //获取文本框的文本 var text = $(’textarea’).val(); //提交一个say事件，服务器收到就会广播 socket.emit(’say’, { username: ’Username hehe’ text: text });});
