在http服務器運行之后,使用listen方法為該http服務器附加一個socket.io服務器.

代碼如下:
var sio=require("scoket.io");
var socket=sio.listen(server);

socket就是在server基礎上創建的一個socket.io服務器.

當客戶端與服務器端建立連接時,觸發socket.io服務的connection事件.

代碼如下:
socket.on("connection",function(socket){
});

回調函數中的socket參數是服務器端與客戶端建立連接的socket端口對象.

當接收到客戶端發送的消息時,發出socket端口對象的message事件.

代碼如下:
socket.on("message",function(msg){
});

回調函數的參數是客戶端發送的消息.

可以使用socket.send(msg)向客戶端發送一個消息.

當服務器端可客戶端的連接斷開時觸發disconnect事件.

代碼如下:
socket.on("disconnect",funciton(){
});

該回調函數不適用任何參數.

服務器端server.js代碼:

代碼如下:
var http=require("http");
var sio=require("socket.io");
var fs=require("fs");
var server=http.createServer(function (req,res) {
res.writeHead(200,{"Content-type":"text/html"});
res.end(fs.readFileSync("./index.html"));
});
server.listen(1337);
var socket=sio.listen(server);
socket.on("connection", function (socket) {
console.log("客戶端建立連接");
socket.send("你好");
socket.on("message", function (msg) {
console.log("接收到一個消息:"+msg);
});
socket.on("disconnect", function () {
console.log("客戶端斷開連接.");
});
});

創建客戶端index.html代碼:

代碼如下:

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com