Home Web Front-end JS Tutorial Introduction to socket.io learning tutorial in node.js (2)

Introduction to socket.io learning tutorial in node.js (2)

May 03, 2017 am 10:02 AM

socket.io provides real-time two-way communication based on events. The following article mainly introduces relevant information about the basic applications of socket.io. It has certain reference and learning value for everyone. Friends who need it can read it together. Take a look.

Preface

Socket.IO supports timely, two-way and event-based communication. It works on every platform, every browser, and every device with the same reliability and speed.

  • Real-time analysis: Push data to clients where they will be represented as real-time counters, charts or log clients.

  • Real-time communication and chat: It only takes a few lines of code to write a Socket.IO "Hello, World" chat application.

  • Binary streaming transmission: Starting from version 1.0, Socket.IO supports any form of binary file transmission, such as: pictures, videos, audio, etc.

  • Document merging: Allow multiple users to edit a document at the same time and be able to see the changes made by each user.

Server and client connection

socket.io provides both server and client connections API

The server socket.io must bind an http.Server instance

Bind http.Server

1, Implicit Binding

Implicit binding is performed by passing in the port when instantiating or calling the listen or attach function after instantiation. Socket.io internally instantiates and listens to http.Server

. When instantiating, the incoming port

let io = require('socket.io')(3000)
Copy after login

is directly bound through the listen or attach function. listen is synonymous with attach

let io = require('socket.io') 
io.listen(3000) // io.attach(3000)
Copy after login

2. Display binding

You can manually specify http.Server

Bind when instantiated

let server = require('http').Server(); 
let io = require('socket.io')(server)

server.listen(3000)
Copy after login

Binding through listen or attach

let server = require('http').Server(); 
let io = require('socket.io')()

io.listen(server) // io.attach(server)

server.listen(3000)
Copy after login

can bind http frameworks such as express or koa

express

let app = require('express') 
let server = require('http').Server(app) 
let io = require('socket.io')(server)

app.listen(3000)
Copy after login

koa

let app = require('koa')() 
let server = require('http').Server(app.callback())

let io = require('socket.io')(server)

app.listen(3000)
Copy after login

Listen to the connection status

When the server and client are successfully connected, the server will listen to the connection and connect events (connection and connect are synonymous), and the client The connect event will be monitored. When the connection is disconnected, the server's socket corresponding to the client and the client will both monitor the disconnect event.

Server code

let server = require('http').Server() 
let io = require('socket.io')(server)

server.listen(3000); 
io.on('connection', socket => { 
 console.log('connect')
 socket.on('disconnect', () => {
 console.log('disconnect')
 })
 socket.disconnect()
})
Copy after login

Print after running

connect 
disconnect
Copy after login
Copy after login

Client code

let socket = io('http://localhost:3000') 
socket.on('connect', () => { 
 console.log('connect')
})
socket.on('disconnect', () => { 
 console.log('disconnect')
})
Copy after login

Print after running

connect 
disconnect
Copy after login
Copy after login

Transfer data

Server and client The socket on the client side is an associated EventEmitter object. Events sent by the client socket can be received by the server socket, and events sent by the server socket can also be accepted by the client. Based on this mechanism, two-way communication can be achieved.

Now simulate a situation like this: the client keeps sending random numbers. When the random number is greater than 0.95, the server delays for 1s and then sends a warning and the number of warnings to the client

Server Code

let server = require('http').Server() 
let io = require('socket.io')(server)

server.listen(3000); 
io.on('connection', socket => { 
 socket.on('random', value => {
 console.log(value)
 if (value > 0.95) {
  if (typeof socket.warning === 'undefined') socket.warning = 0
  setTimeout(() => {
  socket.emit('warn', ++socket.warning)
  }, 1000)
 }
 })
})
Copy after login

The socket object can be used to store status information and custom data, such as socket.warning

Client code

let socket = io('http://localhost:3000') 
let interval = setInterval(() => { 
 socket.emit('random', Math.random())
}, 500)
socket.on('warn', count => { 
 console.log('warning count: ' + count)
})
socket.on('disconnect', () => { 
 clearInterval(interval)
})
Copy after login

Transport stream

socket.io can handle streams

Server code

io.on('connection', function (socket) { 
 let stream = ss.createStream()
 ss(socket).emit('script', stream)
 fs.createReadStream(__filename).pipe(stream)
})
Copy after login

Client code

let socket = io('http://localhost:3000') 
ss(socket).on('script', stream => { 
 let buffer = '' 
 stream.on('data', data => {
 buffer += data.toString()
 })
 stream.on('end', () => {
 console.log(buffer)
 })
})
Copy after login

The above is the detailed content of Introduction to socket.io learning tutorial in node.js (2). For more information, please follow other related articles on the PHP Chinese website!

Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

Video Face Swap

Video Face Swap

Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Tools

Notepad++7.3.1

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

Detailed graphic explanation of the memory and GC of the Node V8 engine Detailed graphic explanation of the memory and GC of the Node V8 engine Mar 29, 2023 pm 06:02 PM

This article will give you an in-depth understanding of the memory and garbage collector (GC) of the NodeJS V8 engine. I hope it will be helpful to you!

An article about memory control in Node An article about memory control in Node Apr 26, 2023 pm 05:37 PM

The Node service built based on non-blocking and event-driven has the advantage of low memory consumption and is very suitable for handling massive network requests. Under the premise of massive requests, issues related to "memory control" need to be considered. 1. V8’s garbage collection mechanism and memory limitations Js is controlled by the garbage collection machine

Let's talk about how to choose the best Node.js Docker image? Let's talk about how to choose the best Node.js Docker image? Dec 13, 2022 pm 08:00 PM

Choosing a Docker image for Node may seem like a trivial matter, but the size and potential vulnerabilities of the image can have a significant impact on your CI/CD process and security. So how do we choose the best Node.js Docker image?

Let's talk in depth about the File module in Node Let's talk in depth about the File module in Node Apr 24, 2023 pm 05:49 PM

The file module is an encapsulation of underlying file operations, such as file reading/writing/opening/closing/delete adding, etc. The biggest feature of the file module is that all methods provide two versions of **synchronous** and **asynchronous**, with Methods with the sync suffix are all synchronization methods, and those without are all heterogeneous methods.

Node.js 19 is officially released, let's talk about its 6 major features! Node.js 19 is officially released, let's talk about its 6 major features! Nov 16, 2022 pm 08:34 PM

Node 19 has been officially released. This article will give you a detailed explanation of the 6 major features of Node.js 19. I hope it will be helpful to you!

Let's talk about the GC (garbage collection) mechanism in Node.js Let's talk about the GC (garbage collection) mechanism in Node.js Nov 29, 2022 pm 08:44 PM

How does Node.js do GC (garbage collection)? The following article will take you through it.

Let's talk about the event loop in Node Let's talk about the event loop in Node Apr 11, 2023 pm 07:08 PM

The event loop is a fundamental part of Node.js and enables asynchronous programming by ensuring that the main thread is not blocked. Understanding the event loop is crucial to building efficient applications. The following article will give you an in-depth understanding of the event loop in Node. I hope it will be helpful to you!

What should I do if node cannot use npm command? What should I do if node cannot use npm command? Feb 08, 2023 am 10:09 AM

The reason why node cannot use the npm command is because the environment variables are not configured correctly. The solution is: 1. Open "System Properties"; 2. Find "Environment Variables" -> "System Variables", and then edit the environment variables; 3. Find the location of nodejs folder; 4. Click "OK".

See all articles