Socket搭建即時通訊伺服器

// 請求頭
GET ws://localhost:12345/websocket/test.html HTTP/1.1
Origin: http://localhost
Connection: Upgrade
Host: localhost:12345
Sec-WebSocket-Key: JspZdPxs9MrWCt3j6h7KdQ==
Upgrade: websocket 
Sec-WebSocket-Version: 13
// Sec-WebSocket-Key: 叫“夢幻字串”是個金鑰，只有有這個金鑰 伺服器才能通過解碼認出來，這是個WB的請求，要建立TCP連線了！！！如果這個字串沒有按照加密規則加密，那服務端就認不出來，就會認為這整個協議就是個HTTP請求。更不會開TCP。其他的欄位都可以隨便設定，但是這個欄位是最重要的欄位，標識WB協議的一個欄位


// 響應頭
HTTP/1.1 101 Web Socket Protocol Handshake
WebSocket-Location: ws://localhost:12345/websocket/test.php
Connection: Upgrade
Upgrade: websocket
Sec-WebSocket-Accept: zUyzbJdkVJjhhu8KiAUCDmHtY/o= 
WebSocket-Origin: http://localhost

// Sec-WebSocket-Accept: 叫“夢幻字串”，和上面那個夢幻字串作用一樣。不同的是，這個字串是要讓客戶端辨認的，客戶端拿到後自動解碼。並且辨認是不是一個WB請求。然後進行相應的操作。這個欄位也是重中之重，不可隨便修改的。加密規則，依然是有規則的

var Socket = new WebSocket(url, [protocol] );

// 客戶端
var socket = new WebSocket("ws://localhost:9090")

// 建立 web socket 連線成功觸發事件
socket.onopen = function () {
// 使用send傳送資料
socket.send("傳送資料")
console.log(socket.bufferedAmount)
alert('資料傳送中')
}

// 接受服務端資料是觸發事件
socket.onmessage = function (evt) {
var received_msg = evt.data
alert('資料已經接受..')
}

// 斷開 websocket 連線成功觸發事件
socket.onclose = function () {
alert('連結已經關閉')
console.log(socket.readyState)
}

// 1. 進入噹噹前資料夾
cd ...

// 2. 建立package.json檔案
npm init

/// 3. 匯入庫
npm install socket.io --sava
npm install express --sava

// 引入http模組
var http = require('http')

// 面向express框架開發，載入express框架，方便處理get,post請求
var express = require('express')

// 建立web伺服器
var server = http.Server(express)

// 引入socket.io模組
var socketio = require('socket.io')

// 建立愛你socket伺服器
var serverSocket = socketio(server)


server.listen(9090)
console.log('監聽9090')

// 監聽客戶端有沒有連線成功,如果連線成功,服務端會發送connection事件,通知客戶端連線成功
// serverSocket: 服務端, clientSocket: 客戶端
serverSocket.on('connection', function (clientSocket) {
// 建立socket連線成功
console.log('建立連線成功')

console.log(clientSocket)
})

// 第一種, SocketIOClientConfiguration: 可選引數
public init(socketURL: URL, config: SocketIOClientConfiguration = [])

// 第二種, 底層還是使用的第一種方式建立
public convenience init(socketURL: URL, config: [String: Any]?) {
self.init(socketURL: socketURL, config: config?.toSocketConfiguration() ?? [])
}

public enum SocketIOClientOption : ClientOption {
/// 使用壓縮的方式進行傳輸
case compress
/// 通過字典內容連線
case connectParams([String: Any])
/// NSHTTPCookies的陣列, 在握手過程中傳遞, Default is nil.
case cookies([HTTPCookie])
/// 新增自定義請求頭初始化來請求, 預設為nil
case extraHeaders([String: String])
/// 將為每個連線建立一個新的connect, 如果你在重新連線有bug時使用.
case forceNew(Bool)
/// 傳輸是否使用HTTP長輪詢, 預設false
case forcePolling(Bool)
/// 是否使用 WebSockets. Default is `false`
case forceWebsockets(Bool)
/// 排程handle的執行佇列, 預設在主佇列
case handleQueue(DispatchQueue)
/// 是否列印除錯資訊. Default is false
case log(Bool)
/// 可自定義SocketLogger除錯日誌
case logger(SocketLogger)
/// 自定義伺服器使用的路徑.
case path(String)
/// 連結失敗時, 是否重新連結, Default is `true`
case reconnects(Bool)
/// 重新連線多少次. Default is `-1` (無限次)
case reconnectAttempts(Int)
/// 等待重連時間. Default is `10`
case reconnectWait(Int)
/// 是否使用安全傳輸, Default is false
case secure(Bool)
/// 設定允許那些證書有效
case security(SSLSecurity)
/// 自簽名只能用於開發模式
case selfSigned(Bool)
/// NSURLSessionDelegate 底層引擎設定. 如果你需要處理自簽名證書. Default is nil.
case sessionDelegate(URLSessionDelegate)
}

// 注意協議：ws開頭
guard let url = URL(string: "ws://localhost:9090") else { return }
let manager = SocketManager(socketURL: url, config: [.log(true), .compress])
// SocketIOClient
let socket = manager.defaultSocket

// 回撥閉包
public typealias NormalCallback = ([Any], SocketAckEmitter) -> ()

// on方法
@discardableResult
open func on(_ event: String, callback: @escaping NormalCallback) -> UUID

// SocketClientEvent: 接受列舉型別的on方法
@discardableResult
open func on(clientEvent event: SocketClientEvent, callback: @escaping NormalCallback) -> UUID {
// 這裡呼叫的是上面的on方法
return on(event.rawValue, callback: callback)
}

guard let url = URL(string: "ws://localhost:9090") else { return }

let manager = SocketManager(socketURL: url, config: [.log(true), .compress])
let socket = manager.defaultSocket

// 監聽連結成功
socket.on(clientEvent: .connect) { (data, ack) in
print("連結成功")
print(data)
print(ack)
}

socket.connect()

// 監聽連結成功
socket.on(clientEvent: .connect) { (data, ack) in
print("連結成功")
print(data)
print(ack)
}

// 建立一個連線到伺服器. 連線成功會觸發 "connect"事件
open func connect()

// 連線到伺服器. 如果連線超時,會呼叫handle
open func connect(timeoutAfter: Double, withHandler handler: (() -> ())?)

// 重開一個斷開連線的socket
open func disconnect()

// 向伺服器傳送事件, 引數一: 事件的名稱，引數二: 傳輸的資料組
open func emit(_ event: String, with items: [Any])

// 監聽socket連線
socket.on('connection',function(s){

console.log('監聽到客戶端連線');

// data:客戶端陣列第0個元素
// data1:客戶端陣列第1個元素
s.on('chat',function(data,data1){

console.log('監聽到chat事件');

console.log(data,data1);

});
});

// 給當前客戶端傳送資料，其他客戶端收不到.
socket.emit('chat', '伺服器' + data)

// 發給所有客戶端，不包含當前客戶端
socket.emit.broadcast.emit('chat', '發給所有客戶端,不包含當前客戶端' + data)

// 發給所有客戶端，包含當前客戶端
socket.emit.sockets.emit('chat', '發給所有客戶端,包含當前客戶端' + data)

// join和leave
io.on('connection', function(socket){
socket.join('some room');
// socket.leave('some room');
});
 
// say to room
io.to('some room').emit('some event'):
io.in('some room').emit('some event'):