❶ 如何用websocket+nodejs实现web即时通信服务端
用websocket+nodejs实现web即时通信服务端，Socketio和nodejs配的不错，建立了socket就可以listen和broadcast。
❷ c#怎么向nodejs的socket.io发送请求
1. 简介
首先是Socket.IO的官方网站：http://socket.io
官网非常简洁，甚至没有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.io
2.2 结合express来构建服务器
express是一个小巧的Node.js的Web应用框架，在构建HTTP服务器时经常使用到，所以直接以Socket.IO和express为例子来讲解。
复制代码
代码如下:
var express = require('express')
,
app = express()
, server = require('http').createServer(app)
, io
= require('socket.io').listen(server);
server.listen(3001);
若不使用express，请参考socket.io/#how-to-use
3. 基本使用方法
主要分为服务器端和客户端两段代码，都非常简单。
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 = io.connect('http://localhost');
socket.on('news', function
(data) {
console.log(data);
socket.emit('other event', {
my: 'data' });
});
</script>
有两点要注意的：socket.io.js路径要写对，这个js文件实际放在了服务器端的node_moles文件夹中，在请求这个文件时会重定向，因此不要诧异服务器端不存在这个文件但为什么还能正常工作。当然，你可以把服务器端的socket.io.js这个文件拷贝到本地，使它成为客户端的js文件，这样就不用每次都向Node服务器请求这个js文件，增强稳定性。第二点是要用var
socket =
io.connect('网站地址或ip');来获取socket对象，接着就可以使用socket来收发事件。关于事件处理，上面的代码表示收到“news”事件后，打印收到的数据，并向服务器发送“other
event”事件。
注：内置默认的事件名例如“disconnect”表示客户端连接断开，“message”表示收到消息等等。自定义的事件名称，尽量不要跟Socket.IO中内置的默认事件名重名，以免造成不必要的麻烦。
4. 其他常用API
1).向所有客户端广播：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[socketId] = {
socket:
socket
};
//用户进入聊天室事件，向其他在线用户广播其用户名
socket.on('join', function
(data) {
socket.broadcast.emit('broadcast_join',
data);
connectionList[socketId].username =
data.username;
});
//用户离开聊天室事件，向其他在线用户广播其离开
socket.on('disconnect', function
() {
if (connectionList[socketId].username) {
socket.broadcast.emit('broadcast_quit', {
username:
connectionList[socketId].username
});
}
delete connectionList[socketId];
});
//用户发言事件，向其他在线用户广播其发言内容
socket.on('say', function (data)
{
socket.broadcast.emit('broadcast_say',{
username: connectionList[socketId].username,
text:
data.text
});
});
})
};
Client(socketChatClient.js)
复制代码
代码如下:
var socket =
io.connect('http://localhost');
//连接服务器完毕后，马上提交一个“加入”事件，把自己的用户名告诉别人
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
});
});
❸ nodejs 怎么和exe进行socket通信
完成 Sever --> Client 的单向通讯。
[javascript] view plain
// Sever --> Client 的单向通讯
var net = require('net');
var chatServer = net.createServer();
chatServer.on('connection', function(client) {
client.write('Hi!\n'); // 服务端向客户端输出信息，使用 write() 方法
client.write('Bye!\n');
client.end(); // 服务端结束该次会话
});
chatServer.listen(9000);
客户端可以是系统自带的 Telnet：
[plain] view plain
telnet 127.0.0.1 9000
执行 telnet 后，与服务点连接，反馈 Hi! Bye! 的字符，并立刻结束服务端程序终止连接。如果我们要服务端接到到客户端的信息？可以监听 server.data 事件并且不要中止连接（否则会立刻结束无法接受来自客户端的消息）：
[javascript] view plain
// 在前者的基础上，实现 Client --> Sever 的通讯，如此一来便是双向通讯
var net = require('net');
var chatServer = net.createServer(),
clientList = [];
chatServer.on('connection', function(client) {
// JS 可以为对象自由添加属性。这里我们添加一个 name 的自定义属性，用于表示哪个客户端（客户端的地址+端口为依据）
client.name = client.remoteAddress + ':' + client.remotePort;
client.write('Hi ' + client.name + '!\n');
clientList.push(client);
client.on('data', function(data) {
broadcast(data, client);// 接受来自客户端的信息
});
});
function broadcast(message, client) {
for(var i=0;i<clientList.length;i+=1) {
if(client !== clientList[i]) {
clientList[i].write(client.name + " says " + message);
}
}
}
chatServer.listen(9000);
这里要说明一下的是，不不同操作系统对端口范围的限制不一样，有可能是随机的。
那么上面是不是一个完整功能的代码呢？我们说还有一个问题没有考虑进去：那就是一旦某个客户端退出，却仍保留在 clientList 里面，这明显是一个空指针（NullPoint）。如果是在这样的话我们写程序太脆弱了，能不能更健壮一些？——请接着看。
首先我们简单地把 client 从数组 clientList 中移除掉。完成这工作一点都不困难。Node TCP API 已经为我们提供了 end 事件，即客户端中止与服务端连接的时候发生。移除 client 对象的代码如下：
[javascript] view plain
chatServer.on('connection', function(client) {
client.name = client.remoteAddress + ':' + client.remotePort
client.write('Hi ' + client.name + '!\n');
clientList.push(client)
client.on('data', function(data) {
broadcast(data, client)
})
client.on('end', function() {
clientList.splice(clientList.indexOf(client), 1); // 删除数组中的制定元素。这是 JS 基本功哦~
})
})
但是我们还不敢说上述代码很健壮，因为一旦 end 没有被触发，异常仍然存在着。下面我们看看解决之道：重写 broadcast()：
[javascript] view plain
function broadcast(message, client) {
var cleanup = []
for(var i=0;i<clientList.length;i+=1) {
if(client !== clientList[i]) {
if(clientList[i].writable) { // 先检查 sockets 是否可写
clientList[i].write(client.name + " says " + message)
} else {
cleanup.push(clientList[i]) // 如果不可写，收集起来销毁。销毁之前要 Socket.destroy() 用 API 的方法销毁。
clientList[i].destroy()
}
}
} //Remove dead Nodes out of write loop to avoid trashing loop index
for(i=0;i<cleanup.length;i+=1) {
clientList.splice(clientList.indexOf(cleanup[i]), 1)
}
}
TCP API 中还提供一个 error 事件，用于捕捉客户端的异常：
[javascript] view plain
client.on('error', function(e) {
console.log(e);
});
Node 网络编程的 API 还丰富，此次仅仅是个入门，更多的内容请接着看，关于浏览器 Socket 应用。
Socket.IO
前面说到，浏览器虽然也属于客户端的一种，但仅支持“单工”的 HTTP 通讯。有见及此，HTML5 新规范中推出了基于浏览器的 WebSocket，开发了底层的接口，允许我们能进行 更强大的操作，超越以往的 XHR。
如第一个例子那般，我们无须第三方框架就可以直接与 Node TCP 服务器 进行 Socket 通讯。
但我们又要认清一个事实，不是每个浏览器都可以顺利支持 WebSocket 的。于是 Socket.IO （http://socket.io）出现了，它提供了不支持 WebSocket 时候的降级支持，同时使得一些旧版本的浏览器也可以“全双工”地工作。优先使用的顺序如下：
WebSocket
Socket over Flash API
XHR Polling 长连接
XHR Multipart Streaming
Forever Iframe
JSONP Polling
经过封装，我们可以不探究客户端使用上述哪一种技术达致“全双工”；而我们编写代码时，亦无论考虑哪种放法，因为 Socket.IO 给我们的 API 只有一套。了解 Socket.IO 其用法就可以了。
先在浏览器部署 Socket.IO 的前端代码：
[html] view plain
<!DOCTYPE html>
<html>
<body>
<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://localhost:8080');
// 当服务端发送一条消息到客户端，message 事件即被触发。我们把消息在控制台打印出来
socket.on('message', function(data){ console.log(data) })
</script>
</body>
</html>
服务端 Node 代码：
[javascript] view plain
var http = require('http'),
io = require('socket.io'),
fs = require('fs');
// 虽然我们这里使用了同步的方法，那会阻塞 Node 的事件循环，但是这是合理的，因为 readFileSync() 在程序周期中只执行一次，而且更重要的是，同步方法能够避免异步方法所带来的“与 SocketIO 之间额外同步的问题”。当 HTML 文件读取完毕，而且服务器准备好之后，如此按照顺序去执行就能让客户端马上得到 HTML 内容。
var sockFile = fs.readFileSync('socket.html');
// Socket 服务器还是构建于 HTTP 服务器之上，因此先调用 http.createServer()
server = http.createServer();
server.on('request', function(req, res){
// 一般 HTTP 输出的格式
res.writeHead(200, {'content-type': 'text/html'});
res.end(sockFile);
});
server.listen(8080);
var socket = io.listen(server); // 交由 Socket.io 接管
// Socket.io 真正的连接事件
socket.on('connection', function(client){
console.log('Client connected');
client.send('Welcome client ' + client.sessionId); // 向客户端发送文本
});
当客户端连接时，服务端会同时出发两个事件：server.onRequest 和 Socket.onConnection。它们之间有什么区别呢？区别在于 Socket 的是持久性的。
多个 Socket 连接，先是客户端代码：
[html] view plain
<!DOCTYPE html>
<html>
<body>
<script src="/socket.io/socket.io.js"></script>
<script>
var upandrunning = io.connect('http://localhost:8080/upandrunning');
var weather = io.connect('http://localhost:8080/weather');
upandrunning.on('message', function(data){
document.write('<br /><br />Node: Up and Running Update<br />');
document.write(data);
});
weather.on('message', function(data){
document.write('<br /><br />Weather Update<br />');
document.write(data);
});
</script>
</body>
</html>
服务端代码：
[javascript] view plain
var sockFile = fs.readFileSync('socket.html');
server = http.createServer();
server.on('request', function(req, res){
res.writeHead(200, {'content-type': 'text/html'});
res.end(sockFile);
});
server.listen(8080);
var socket = io.listen(server);
socket.of('/upandrunning')
.on('connection', function(client){
console.log('Client connected to Up and Running namespace.');
client.send("Welcome to 'Up and Running'");
});
socket.of('/weather')
.on('connection', function(client){
console.log('Client connected to Weather namespace.');
client.send("Welcome to 'Weather Updates'");
});
如上代码，我们可以划分多个命名空间，分别是 upandrunning 和 weather。
❹ Nodejs的WebSocket模块怎么设置连接超时时间
在建立socket连接时可以很容易设置socket通信的发送和接收超时时间，但是在建立socket通信时，如果是Win98系统，则如果连接失败，则程序会一直等待在哪里，Windows2000默认超时时间是30秒，当然，这个超时时间不算长，但是加入我们要循环扫描一系列端口并且建立连接的话，总的等待时间就会让人忍受不了，下面就以delphi为例进行说明，如何在建立socket的时候设置其超时时间：
//连接，发送和接收时间都设为2秒
SctTimeOut := 2000;
//设置接收数据通信超时
setsockopt(hSock,SOL_SOCKET,SO_RCVTIMEO,@SctTimeOut,SizeOf(Integer));
//设置发送数据通信超时
setsockopt(hSock,SOL_SOCKET,SO_SNDTIMEO,@SctTimeOut,SizeOf(Integer));
//首先，设置通讯为非阻塞模式
dwArg := 1;
RecvLen := ioctlsocket(hSock,FIONBIO,dwArg);
//其次，连接服务器
ZeroMemory(@addr, sizeof(addr));
addr.sin_family := AF_INET;
addr.sin_addr.S_addr := inet_addr(pchar(SvrIP));
addr.sin_port := htons(Strtoint(SvrPort));
RecvLen := 0;
RecvLen := connect(hSock, addr, sizeof(addr));
//再次，设置连接超时时间为2秒
tmOut.tv_sec := 2;
tmOut.tv_usec := 0;
FD_ZERO(recvSet);
FD_SET(hSock, recvSet);
RecvLen := select(0, @recvSet, @recvSet, nil, @tmOut);
//连接失败，报错误信息
if (RecvLen = 0) or (RecvLen = SOCKET_ERROR) then
begin
ErrMsg := '连接服务器失败！';
exit;
end;
//最后，设置通讯为阻塞模式
dwArg := 0;
RecvLen := ioctlsocket(hSock,FIONBIO,dwArg);
//end modify