Node.jsで学ぶsocket.io入門(2)-jsチュートリアル-php.cn

Node.jsで学ぶsocket.io入門(2)

零下一度

リリース： 2017-05-03 10:02:04

オリジナル

1367 人が閲覧しました

socket.io は、イベントに基づいたリアルタイムの双方向通信を提供します。次の記事では、socket.io の基本的なアプリケーションに関する関連情報を主に紹介します。必要な方は参照してください。下に。。

はじめに

Socket.IO は、タイムリーな双方向のイベントベースの通信をサポートします。すべてのプラットフォーム、すべてのブラウザ、すべてのデバイスで同じ信頼性と速度で動作します。

リアルタイム分析: データをクライアントにプッシュし、リアルタイムカウンター、チャート、またはログクライアントとして表示されます。
リアルタイム通信とチャット: Socket.IO「Hello, World」チャットアプリケーションを作成するのに必要なコードはわずか数行です。
バイナリストリーミング: バージョン 1.0 以降、Socket.IO は、画像、ビデオ、オーディオなどのあらゆる形式のバイナリファイル送信をサポートします。
ドキュメントの結合: 複数のユーザーが同時にドキュメントを編集し、各ユーザーが加えた変更を確認できるようにします。

サーバーはクライアントに接続します

socket.ioはサーバーとクライアントの両方のAPIを提供します

サーバーsocket.ioはhttp.Serverインスタンスにバインドする必要があります

http .Serverをバインドする

1. 暗黙的なバインディング

は、インスタンス化するとき、またはインスタンス化後に listen またはattach 関数を呼び出すときにポートを渡すことによって暗黙的にバインドされます。 Socket.io は内部で http.Server をインスタンス化してリッスンしますhttp.Server

实例化时传入端口

let io = require(&#39;socket.io&#39;)(3000)

ログイン後にコピー

直接通过listen或attach函数绑定。listen与attach同义

let io = require(&#39;socket.io&#39;) 
io.listen(3000) // io.attach(3000)

ログイン後にコピー

2、显示绑定

可以手动指定http.Server

实例化时绑定

let server = require(&#39;http&#39;).Server(); 
let io = require(&#39;socket.io&#39;)(server)

server.listen(3000)

ログイン後にコピー

通过listen或attach绑定

let server = require(&#39;http&#39;).Server(); 
let io = require(&#39;socket.io&#39;)()

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

server.listen(3000)

ログイン後にコピー

可以绑定express或koa等http框架

express

let app = require(&#39;express&#39;) 
let server = require(&#39;http&#39;).Server(app) 
let io = require(&#39;socket.io&#39;)(server)

app.listen(3000)

ログイン後にコピー

koa

let app = require(&#39;koa&#39;)() 
let server = require(&#39;http&#39;).Server(app.callback())

let io = require(&#39;socket.io&#39;)(server)

app.listen(3000)

ログイン後にコピー

监听连接状态

当服务器端与客户端连接成功时，服务端会监听到connection和connect事件(connection与connect同义), 客户端会监听到connect事件, 断开连接时服务端的对应到客户端的socket与客户端均会均会监听到disconnect事件

服务端代码

let server = require(&#39;http&#39;).Server() 
let io = require(&#39;socket.io&#39;)(server)

server.listen(3000); 
io.on(&#39;connection&#39;, socket => { 
 console.log(&#39;connect&#39;)
 socket.on(&#39;disconnect&#39;, () => {
 console.log(&#39;disconnect&#39;)
 })
 socket.disconnect()
})

ログイン後にコピー

运行后打印

connect 
disconnect

ログイン後にコピー

客户端代码

let socket = io(&#39;http://localhost:3000&#39;) 
socket.on(&#39;connect&#39;, () => { 
 console.log(&#39;connect&#39;)
})
socket.on(&#39;disconnect&#39;, () => { 
 console.log(&#39;disconnect&#39;)
})

ログイン後にコピー

运行后打印

connect 
disconnect

ログイン後にコピー

传输数据

服务器与客户端的socket是一个关联的EventEmitter对象，客户端socket派发的事件可以通以被服务端的socket接收，服务器端socket派发的事件也可以被客户端接受。基于这种机制，可以实现双向交流。

现在模拟这样一种情况：客户端不停发送随机数，当随机数大于0.95时，服务端延时1s后向客户端发送警告以及警告次数

服务端代码

let server = require(&#39;http&#39;).Server() 
let io = require(&#39;socket.io&#39;)(server)

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

ログイン後にコピー

socket对象可以用来存储状态信息和自定义数据,如socket.warning

インスタンス化の際、受信ポート

let socket = io(&#39;http://localhost:3000&#39;) 
let interval = setInterval(() => { 
 socket.emit(&#39;random&#39;, Math.random())
}, 500)
socket.on(&#39;warn&#39;, count => { 
 console.log(&#39;warning count: &#39; + count)
})
socket.on(&#39;disconnect&#39;, () => { 
 clearInterval(interval)
})

ログイン後にコピー

は listen またはattach 関数を通じて直接バインドされます。 Listen は、attach と同義です

io.on(&#39;connection&#39;, function (socket) { 
 let stream = ss.createStream()
 ss(socket).emit(&#39;script&#39;, stream)
 fs.createReadStream(__filename).pipe(stream)
})

ログイン後にコピー

2. バインディングを表示しますインスタンス化時に http.Server を手動で指定できます

listen または Attach によってバインドします

let socket = io(&#39;http://localhost:3000&#39;) 
ss(socket).on(&#39;script&#39;, stream => { 
 let buffer = &#39;&#39; 
 stream.on(&#39;data&#39;, data => {
 buffer += data.toString()
 })
 stream.on(&#39;end&#39;, () => {
 console.log(buffer)
 })
})

ログイン後にコピー

Express や koa などの http フレームワークにバインドできます

express

rrreee🎜koa🎜rrreee🎜🎜🎜接続ステータスの監視🎜🎜🎜🎜🎜サーバーとクライアントが正常に接続されると、サーバーは接続イベントと接続イベント (接続と接続は同義です) をリッスンし、クライアントは接続が切断されると、クライアントに対応するサーバーのソケットとクライアントの両方が切断イベントを監視します🎜🎜サーバーコード🎜rrreee🎜実行後の印刷🎜rrreee🎜クライアントコード🎜rrreee🎜実行後の印刷🎜 rrreee🎜🎜🎜データ転送🎜🎜🎜🎜🎜 サーバーソケットとクライアントソケットは関連付けられた EventEmitter オブジェクトであり、クライアントソケットによって送信されたイベントはサーバーソケットによって受信でき、サーバーソケットによって送信されたイベントはクライアントによって受信することもできます。終了は受け入れられました。この仕組みにより双方向通信が可能となります。 🎜🎜ここで、クライアントが乱数を送信し続ける状況をシミュレートします。乱数が 0.95 より大きい場合、サーバーは 1 秒遅れて警告をクライアントに送信します🎜🎜サーバーコード🎜rrreee🎜 ソケットオブジェクトは次のとおりです。 socket.warning などのステータス情報とカスタムデータを保存するために使用されます🎜🎜クライアントコード🎜rrreee🎜🎜🎜トランスポートストリーム🎜🎜🎜🎜🎜socket.io はストリームを処理できます🎜🎜サーバーコード🎜rrreee 🎜クライアントコード🎜rrreee

以上がNode.jsで学ぶsocket.io入門(2)の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。