KingNetwork下載 - KingNetwork原始碼下載

範例

立方體 Unity 範例

Nuget 套件

國王伺服器
https://www.nuget.org/packages/KingNetwork.Server/

國王客戶端
https://www.nuget.org/packages/KingNetwork.Client/

特大號床共享房
https://www.nuget.org/packages/KingNetwork.Shared/

KingServer上使用TCP連接

 // create and start the async server
var server = new KingServer ( port : 7171 ) ;
server . MessageReceivedHandler = OnMessageReceived ;

//ASync execution
await server . StartAsync ( ) ; //You can pass a out var cancellationToken in parameter
//Sync execution
server . Start ( ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IClient client , IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from client { client . Id } , data length { reader . Length ( ) } " ) ;
}

// send a message to all clients
using ( var writer = KingBufferWriter . Create ( ) )
{
    writer . Write ( "Test message!" ) ;
    server . SendMessageToAll ( writer ) ;
}

// stop the server when you don't need it anymore
server . Stop ( ) ;

在 KingClient 上使用 TCP 連接

 // create and connect the client
var client = new KingClient ( ) ;
client . MessageReceivedHandler = OnMessageReceived ;
client . Connect ( "127.0.0.1" , 7171 ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from server, data length { reader . Length ( ) } " ) ;
}

/// send a message to server
using ( var writer = KingBufferWriter . Create ( )
{
    writer . Write ( "Test message!" ) ;
    client . SendMessage ( writer ) ;
}

// disconnect from the server when we are done
client . Disconnect ( ) ;

在 KingServer 上使用 UDP 連接

 // create and start the server
var server = new KingServer ( listenerType : NetworkListenerType . UDP , port : 7171 ) ;
server . MessageReceivedHandler = OnMessageReceived ;

//ASync execution
await server . StartAsync ( ) ; //You can pass a out var cancellationToken in parameter
//Sync execution
server . Start ( ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IClient client , IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from client { client . Id } , data length { reader . Length ( ) } " ) ;
}

// send a message to all clients
using ( var writer = KingBufferWriter . Create ( ) )
{
    writer . Write ( "Test message!" ) ;
    server . SendMessageToAll ( writer ) ;
}

// stop the server when you don't need it anymore
server . Stop ( ) ;

在 KingClient 上使用 UDP 連接

 // create and connect the client
var client = new KingClient ( listenerType : NetworkListenerType . UDP ) ;
client . MessageReceivedHandler = OnMessageReceived ;
client . Connect ( "127.0.0.1" , 7171 ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from server, data length { reader . Length ( ) } " ) ;
}

/// send a message to server
using ( var writer = KingBufferWriter . Create ( )
{
    writer . Write ( "Test message!" ) ;
    client . SendMessage ( writer ) ;
}

// disconnect from the server when we are done
client . Disconnect ( ) ;

在 KingServer 上使用 RUDP 連接

 // create and start the server
var server = new KingServer ( listenerType : NetworkListenerType . RUDP , port : 7171 ) ;
server . MessageReceivedHandler = OnMessageReceived ;

//ASync execution
await server . StartAsync ( ) ; //You can pass a out var cancellationToken in parameter
//Sync execution
server . Start ( ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IClient client , IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from client { client . Id } , data length { reader . Length ( ) } " ) ;
}

// send a message to all clients
using ( var writer = KingBufferWriter . Create ( ) )
{
    writer . Write ( "Test message!" ) ;
    //You can use RudpMessageType.Reliable to send Reliable messages and RudpMessageType.Unreliable to send Unreliable messages
    server . SendMessageToAll ( writer , RudpMessageType . Reliable ) ;
}

// stop the server when you don't need it anymore
server . Stop ( ) ;

在 KingClient 上使用 RUDP 連接

 // create and connect the client
var client = new KingClient ( listenerType : NetworkListenerType . RUDP ) ;
client . MessageReceivedHandler = OnMessageReceived ;
client . Connect ( "127.0.0.1" , 7171 ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from server, data length { reader . Length ( ) } " ) ;
}

/// send a message to server
using ( var writer = KingBufferWriter . Create ( )
{
    writer . Write ( "Test message!" ) ;
    //You can use RudpMessageType.Reliable to send Reliable messages and RudpMessageType.Unreliable to send Unreliable messages
    client . SendMessage ( writer , RudpMessageType . Reliable ) ;
}

// disconnect from the server when we are done
client . Disconnect ( ) ;

在KingServer上使用WebSocket連接

 // create and start the server
var server = new KingServer ( listenerType : NetworkListenerType . WSText , port : 7171 ) ; // Or NetworkListenerType.WSBinary
server . MessageReceivedHandler = OnMessageReceived ;

//ASync execution
await server . StartAsync ( ) ; //You can pass a out var cancellationToken in parameter
//Sync execution
server . Start ( ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IClient client , IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from client { client . Id } , data length { reader . Length ( ) } " ) ;
}

// send a message to all clients
using ( var writer = KingBufferWriter . Create ( ) )
{
    writer . Write ( "Test message!" ) ;
    server . SendMessageToAll ( writer ) ;
}

// stop the server when you don't need it anymore
server . Stop ( ) ;

在 KingClient 上使用 WebSocket 連接

 // create and connect the client
var client = new KingClient ( listenerType : NetworkListenerType . WSText ) ; // Or NetworkListenerType.WSBinary
client . MessageReceivedHandler = OnMessageReceived ;
client . Connect ( "127.0.0.1" , 7171 ) ;

// implements the callback for MessageReceivedHandler
private void OnMessageReceived ( IKingBufferReader reader )
{
    Console . WriteLine ( $ "Received data from server, data length { reader . Length ( ) } " ) ;
}

/// send a message to server
using ( var writer = KingBufferWriter . Create ( )
{
    writer . Write ( "Test message!" ) ;
    client . SendMessage ( writer ) ;
}

// disconnect from the server when we are done
client . Disconnect ( ) ;

TCP 基準測試

連接測試
我們還透過產生 1 個伺服器和 1000 個客戶端來僅測試原始 KingNetwork 庫，每個客戶端每秒發送 14 次 100 字節，伺服器將相同的訊息回顯給每個客戶端。測試計算機：Acer F 15，配備 2.9 GHz Intel Core i7 7gen 處理器和 32 GB 記憶體 DDR4。
測試結果：