直播行業為贏得更廣泛用戶的青睞，自然要不斷開發更有趣的玩法、模式，在直播源碼中加入主播PK功能就是一種提高直播互動性、激發用戶好勝心的方法，一方面這種方法可以吸引更多用戶觀看，增加主播的曝光率，另一方面它又能激發用戶的購買欲，增加平臺和主播的收入。

PK功能可以使用當下十分流行的Socket.IO為基礎來實現。Socket.I O 是一個面向實時 web 應用的 JavaScript 庫。它使服務器和客戶端之間實時雙向的通信成為可能。它由兩個部分組成：客戶端庫和一個面向Node.js的服務端庫。像Node.js一樣，它也是事件驅動的。并且它有一個優勢，它會自動選擇合適的雙向通信協議。我們充分利用了socket.io的優勢，實現了對直播源碼中PK功能流程的控制。

首先，對Socket.IO的App客戶端進行初始化設置，連接服務端(基礎代碼如下)：

try {

IO.Options option = new IO.Options();

option.forceNew = true;

option.reconnection = true;

option.reconnectionDelay = 2000;

mSocket = IO.socket(AppConfig.getInstance().getSocketServer(), option);

mSocketHandler = new SocketHandler();

} catch (Exception e) {

e.printStackTrace();

L.e(TAG, "socket異常--->" + e.getMessage());

}

public SocketUtil connect(String liveuid, String stream) {

if (mSocket != null) {

mSocket.on(Socket.EVENT_CONNECT, mConnectListener);//連接成功

mSocket.on(Socket.EVENT_DISCONNECT, mDisConnectListener);//斷開連接

mSocket.on(Socket.EVENT_CONNECT_ERROR, mErrorListener);//連接錯誤

mSocket.on(Socket.EVENT_CONNECT_TIMEOUT, mTimeOutListener);//連接超時

mSocket.on(Socket.EVENT_RECONNECT, mReConnectListener);//重連

mSocket.on(CONN, onConn);//連接socket消息

mSocket.on(BROADCAST, onBroadcast);//接收服務器廣播的具體業務邏輯相關的消息

mSocket.connect();

mLiveuid = liveuid;

mStream = stream;

}

return this;

}

然后再與服務端實現通信。只需要簡單傳入參數，并emit到服務端，服務端接收后通過邏輯處理，向相應的App端轉發socket信息，這時，接收到消息的客戶端根據socket的method、action等特定字符判斷是否需要作出相應操作，若接收到的信息是自己需要的，則作出相應操作，否則不響應，至此，一個通訊流程就這樣完成了。

public void anchorBusy(String touid) {

if (mSocket == null) {

return;

}

mSocket.emit(SEND,

new SendSocketBean()

.param("_method_", LINK_MIC) ??//參數

.param("action", 7) ?//參數

.param("msgtype", 10) //參數

.param("touid", touid) ?//參數

.create()

);

}

通過使用Socket.I O，可以實現A客戶端與服務端與B客戶端進行連麥PK的操作，當然，Socket.IO還能做更多的事。

總結

以上是生活随笔為你收集整理的php直播pk规则,直播源码中的主播PK功能是如何实现的的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。