KingNetworkダウンロード - KingNetworkソースコードのダウンロード

例

キューブ Unity の例

ナゲットパッケージ

キングサーバー
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 台のクライアントを生成し、各クライアントが 100 バイトを 1 秒あたり 14 回送信し、サーバーが同じメッセージを各クライアントにエコーバックすることで、生の KingNetwork ライブラリのみをテストします。テストコンピューター: 2,9 GHz Intel Core i7 7gen プロセッサーと 32 GB RAM DDR4 を搭載した Acer F 15。
テスト結果: