nodejs 安裝mysql、socket.io 插件
使用cmd窗口命令,代碼如下:
cd c:\Program Files (x86)\nodejs //進入nodejs 安裝目錄中nodejs目錄下 執行命令行: c:\Program Files (x86)\nodejs\npm install mysql //安裝mysql插件 c:\Program Files (x86)\nodejs\npm install socket.io //安裝socket.io 插件 ....
Socket.IO是一個WebSocket庫,包括了客戶端的js和服務器端的nodejs;
socket.io的目標是構建可以在不同瀏覽器和移動設備上使用的實時應用。
socket.io 會自動根據瀏覽器從WebSocket、AJAX長輪詢、Iframe流等等各種方式中選擇最佳的方式來實現網絡實時應用,非常方便和人性化,而且支持的瀏覽器最低達IE5.5,可以滿足大部分需求。
一 使用方法
-
io.sockets.on函數
io.sockets.on 函數 接受字符串"connection"作為客戶端發起連接的事件,當連接成功后,調用帶有socket參數的回調函數。我們在使用socket.IO的時候,基本上都在這個回調函數里面處理用戶的請求。示例代碼;
服務器端 io.sockets.on('connection', function (socket) { socket.emit('news', { hello: 'world' }); socket.on('other event', function (data) { console.log(data); }); });
2. socket最關鍵的是emit和on兩個函數,
socket.emit 表示提交(發出)一個事件(事件名稱用字符串表示),事件名稱可以自定義,也有一些默認的事件名稱,緊接著是一個對象,表示向該socket發送的內容;
socket.on 表示接收一個事件(事件名稱用字符串表示),緊接著是收到事件調用的回調函數,其中data是收到的數據。
在上面的例子中,我們發送了news事件和收到了other event事件,那么客戶端應該會有對應的接收和發送事件。沒錯,客戶端代碼和服務器正好相反,而且非常相似。
客戶端代碼: <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_modules文件夾中,在請求這個文件時會重定向,因此不要詫異服務器端不存在這個文件但為什么還能正常工作。當然,你可以把服務器端的socket.io.js這個文件拷貝到本地,使它成為客戶端的js文件,這樣就不用每次都向Node服務器請求這個js文件,增強穩定性。 第二點是要用var socket = io.connect('網站地址或ip');來獲取socket對象,接著就可以使用socket來收發事件。關于事件處理,上面的代碼表示收到“news”事件后,打印收到的數據,并向服務器發送“other event”事件。
二. 其他常用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){})來接收。
三 . 使用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 }); });