❶ 如何用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