Pengenalan kepada HTML5 WebSocket 3 - Kemahiran model komunikasi socket.io

Mengapa socket.io dilahirkan? Sila lihat penerangan teks di bawah.

Mengapa anda memerlukan socket.io?

Node.js menyediakan persekitaran operasi bahagian pelayan yang cekap, tetapi disebabkan sokongan berbeza untuk HTML5 pada bahagian penyemak imbas, agar serasi dengan semua penyemak imbas, memberikan pengalaman pengguna masa nyata yang sangat baik dan menyediakan pelanggan dan perkhidmatan untuk pengaturcara Untuk menyediakan pengalaman pengaturcaraan yang konsisten, socket.io dilahirkan.

Matlamat reka bentuk socket.io adalah untuk menyokong mana-mana pelayar dan mana-mana peranti mudah alih. Pada masa ini menyokong penyemak imbas PC arus perdana (IE, Safari, Chrome, Firefox, Opera, dll.) dan penyemak imbas Mudah Alih (iphone Safari/ipad Safari/android WebKit/WebOS WebKit, dsb.).

Socket.io adalah berdasarkan node.js dan memudahkan API WebSocket, menyatukan pelbagai API komunikasi. Ia menyokong: WebSocket, Flash Socket, undian panjang AJAX, penstriman berbilang bahagian AJAX, Forever IFrame, tinjauan JSONP.

Socket.io menyelesaikan masalah komunikasi masa nyata dan menyatukan kaedah pengaturcaraan pelayan dan pelanggan. Selepas memulakan soket, ia seperti mewujudkan saluran paip antara pelanggan dan pelayan, dan kedua-dua pihak boleh berkomunikasi antara satu sama lain.

Pasang

Laksanakan dalam baris arahan: npm install socket.io untuk memasang.

Model pengaturcaraan sisi pelayan

Pengaturcaraan sisi pelayan masih sama seperti pelayan biasa, memulakan pelayan, menyediakan perkhidmatan dan memproses acara.

Sebagai contoh, pelayan.js berikut:

var http = require('http')
  , url = require('url')
  , fs = require('fs')
  , server;
server = http.createServer(function(req, res){
  // your normal server code
  var path = url.parse(req.url).pathname;
  switch (path){
  case '/':
   res.writeHead(200, {'Content-Type': 'text/html'});
   res.write('<h1>Hello! Try the <a href="/index.html">Socket.io Test</a></h1>');
   res.end();
   break;
  case '/index.html':
   fs.readFile(__dirname + path, function(err, data){
    if (err) return send404(res);
    res.writeHead(200, {'Content-Type': path == 'json.js' &#63; 'text/javascript' : 'text/html'})
    res.write(data, 'utf8');
    res.end();
   });
   break;
  default: send404(res);
  }
}),
send404 = function(res){
  res.writeHead(404);
  res.write('404');
  res.end();
};
server.listen(8080);
var io = require('socket.io').listen(server);
io.sockets.on('connection', function(socket){
 console.log("Connection " + socket.id + " accepted.");
 socket.on('message', function(message){
    console.log("Received message: " + message + " - from client " + socket.id);
 });
 socket.on('disconnect', function(){
  console.log("Connection " + socket.id + " terminated.");
 });
});

Salin selepas log masuk

Model Pengaturcaraan Pelanggan

Pengaturcaraan pelanggan juga dikendalikan dengan cara yang sama, menyambung ke pelayan dan bertukar maklumat.

Contohnya, halaman index.html berikut:

<!doctype html>
<html>
 <head>
  <title>Socket.io Test</title>
  <script src="/json.js"></script> <!-- for ie -->
  <script src="/socket.io/socket.io.js"></script>
 </head>
 <body>  
  <script>    
  var socket;
  var firstconnect = true;
  function connect() {
   if(firstconnect) {
    socket = io.connect(null);
    socket.on('message', function(data){ message(data); });
    socket.on('connect', function(){ status_update("Connected to Server"); });
    socket.on('disconnect', function(){ status_update("Disconnected from Server"); });
    socket.on('reconnect', function(){ status_update("Reconnected to Server"); });
    socket.on('reconnecting', function( nextRetry ){ status_update("Reconnecting in " 
     + nextRetry + " seconds"); });
    socket.on('reconnect_failed', function(){ message("Reconnect Failed"); });
    firstconnect = false;
   }
   else {
    socket.socket.reconnect();
   }
  }
  function disconnect() {
   socket.disconnect();
  }
  function message(data) {
   document.getElementById('message').innerHTML = "Server says: " + data;
  }
  function status_update(txt){
   document.getElementById('status').innerHTML = txt;
  }
  function esc(msg){
   return msg.replace(/</g, '<').replace(/>/g, '>');
  }
  function send() {
   socket.send("Hello Server!");  
  };    
  </script>
  <h1>Socket.io Test</h1>
  <div><p id="status">Waiting for input</p></div>
  <div><p id="message"></p></div> 
  <button id="connect" onClick='connect()'/>Connect</button>
  <button id="disconnect" onClick='disconnect()'>Disconnect</button>
  <button id="send" onClick='send()'/>Send Message</button>
 </body>
</html>

Salin selepas log masuk

Nota

1. Untuk memulakan pelayan, biarkan ia di nod Buka tetingkap baris arahan, navigasi ke folder di mana server.js berada, dan masukkan node server.js untuk memulakan pelayan.

Dalam index.html di atas, perhatikan baris ini: . Jika anda tidak mahu menggunakan skrip socket.io tempatan, anda boleh

Untuk terus menggunakan skrip awam berikut:

<script src="http://cdn.socket.io/stable/socket.io.js"></script>

Salin selepas log masuk

Juga perhatikan baris ini: soket = io.connect(null).

Nol di sini mewakili sambungan ke perkhidmatan setempat, yang boleh digantikan dengan "localhost" dan kesannya akan sama.

2. Anda boleh menggunakan socket.io untuk memulakan perkhidmatan http secara langsung.

Contohnya:

var io = require('socket.io').listen(80);
io.sockets.on('connection', function (socket) {
 io.sockets.emit('this', { will: 'be received by everyone'});
});

Salin selepas log masuk

3 Socket.io boleh menghantar mesej terus melalui kaedah hantar dan menerima mesej menggunakan acara mesej, contohnya:

//server.js
var io = require('socket.io').listen(80);
io.sockets.on('connection', function (socket) {
 socket.on('message', function () { });
});
//index.html
<script>
 var socket = io.connect('http://localhost/');
 socket.on('connect', function () {
  socket.send('hi');
  socket.on('message', function (msg) {
   // my msg
  });
 });
</script>

Salin selepas log masuk

4. Menghantar dan memproses data

Kedua-dua hujung boleh menghantar acara antara satu sama lain, menghantar data antara satu sama lain dan berkomunikasi antara satu sama lain. Kod untuk menghantar acara ialah: socket.emit(tindakan, data, fungsi), di mana tindakan ialah nama acara, data ialah data, dan fungsi ialah fungsi panggil balik kod untuk memproses acara ialah: soket. on(action, function), if emit sends Apabila terdapat data, parameter dalam fungsi mengandungi data ini. Selain menghantar dan memproses acara terbina dalam, socket.io seperti sambung, putuskan sambungan, mesej. Juga membenarkan penghantaran dan pengendalian acara tersuai, seperti:

//Pelayan:

io.sockets.on('connection', function (socket) {
 socket.emit('news', { hello: 'world' });
 socket.on('my other event', function (data) {
  console.log(data);
 });
});

Salin selepas log masuk

//Pelanggan:

<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('my other event', { my: 'data' });
 });
</script>

Salin selepas log masuk

5. Seperti yang dapat dilihat dari atas, kedua-dua hantar dan pancaran boleh digunakan semasa menghantar data. Cuma emit mengukuhkan pemprosesan acara tersuai.

6. Anda boleh menggunakan kaedah get/set soket pada bahagian pelayan untuk menyimpan data yang berkaitan pada bahagian klien, contohnya:

//Pelayan

var io = require('socket.io').listen(80);
io.sockets.on('connection', function (socket) {
 socket.on('set nickname', function (name) {
  socket.set('nickname', name, function () { socket.emit('ready'); });
 });
 socket.on('msg', function () {
  socket.get('nickname', function (err, name) {
   console.log('Chat message by ', name);
  });
 });
});

Salin selepas log masuk

//Pelanggan

<script>
 var socket = io.connect('http://localhost');
 socket.on('connect', function () {
  socket.emit('set nickname', confirm('What is your nickname&#63;'));
  socket.on('ready', function () {
   console.log('Connected !');
   socket.emit('msg', confirm('What is your message&#63;'));
  });
 });
</script>

Salin selepas log masuk

7. Anda boleh menyiarkan mesej, seperti menghantar mesej kepada semua orang dalam bilik sembang kecuali sambungan soket semasa.

var io = require('socket.io').listen(80);
io.sockets.on('connection', function (socket) {
 socket.broadcast.emit('user connected');
});

Salin selepas log masuk

8. Pelbagai saluran bebas boleh diwujudkan dalam pautan yang sama dan bukannya mewujudkan berbilang pautan. Nama rasmi ini ialah "ruang nama berbilang", seperti contoh rasmi:

var io = require('socket.io').listen(80);
//Server
var chat = io
 .of('/chat')
 .on('connection', function (socket) {
  socket.emit('a message', {
    that: 'only'
   , '/chat': 'will get'
  });
  chat.emit('a message', {
    everyone: 'in'
   , '/chat': 'will get'
  });
 });
var news = io
 .of('/news')
 .on('connection', function (socket) {
  socket.emit('item', { news: 'item' });
 });
//Client
<script>
 var chat = io.connect('http://localhost/chat')
  , news = io.connect('http://localhost/news');
 chat.on('connect', function () {
  chat.emit('hi!');
 });
 news.on('news', function () {
  news.emit('woot');
 });
</script>

Salin selepas log masuk

konfigurasi socket.io

Konfigurasi socket.io sangat mudah Jika anda telah mengkonfigurasi ekspres, anda akan mendapati bahawa mereka menggunakan kaedah yang hampir sama. Mari lihat contoh kecil dahulu:

var io = require('socket.io').listen(80);
io.configure('production', function(){
 io.enable('browser client etag');
 io.set('log level', 1);
 io.set('transports', [
  'websocket'
 , 'flashsocket'
 , 'htmlfile'
 , 'xhr-polling'
 , 'jsonp-polling'
 ]);
});
io.configure('development', function(){
 io.set('transports', ['websocket']);
});

Salin selepas log masuk

Seperti yang anda lihat, socket.io menggunakan konfigurasi, tetapkan, dayakan dan lumpuhkan untuk konfigurasi.

1. Gunakan kaedah konfigurasi untuk mengkonfigurasi tingkah laku dalam persekitaran operasi yang berbeza, iaitu, membolehkan pilihan konfigurasi yang berbeza dalam persekitaran yang berbeza. Parameter pertama konfigurasi ialah persekitaran berjalan, dan parameter kedua ialah fungsi untuk konfigurasi. Persekitaran berjalan biasanya pengeluaran atau pembangunan Sudah tentu, sebarang rentetan boleh digunakan di sini. Jika parameter konfigurasi pertama diabaikan, ini bermakna konfigurasi berikutnya adalah awam dan sah tidak kira apa persekitarannya.

2. Selepas mengkonfigurasi pelbagai persekitaran operasi, bagaimana anda menetapkan persekitaran yang sedang dijalankan? Ini dicapai dengan mengubah suai nilai pembolehubah persekitaran NODE_ENV pada baris arahan.

3. Dalam fungsi konfigurasi konfigurasi, kita boleh menggunakan set, dayakan dan lumpuhkan untuk menetapkan pilihan yang berkaitan.

4. Rujukan untuk item boleh dikonfigurasikan khusus: https://github.com/LearnBoost/Socket.IO/wiki/Configuring-Socket.IO
Rujukan praktikal

Pengenalan Socket.io: http://davidchambersdesign.com/getting-started-with-socket.io/

pemasangan dan arahan penggunaan socket.io: http://socket.io/

Socket.io Wiki: https://github.com/LearnBoost/Socket.IO/wiki