KingNetwork

ตัวอย่าง

ตัวอย่างความสามัคคีของคิวบ์

แพ็คเกจ Nuget

คิงเซิร์ฟเวอร์
https://www.nuget.org/packages/KingNetwork.Server/

ลูกค้าคิง
https://www.nuget.org/packages/KingNetwork.Client/

คิงแบ่งปัน
https://www.nuget.org/packages/KingNetwork.Shared/

การใช้การเชื่อมต่อ TCP บน KingServer

 // 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 ( ) ;

การใช้การเชื่อมต่อ TCP บน KingClient

 // 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 ( ) ;

การใช้การเชื่อมต่อ UDP บน KingServer

 // 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 ( ) ;

การใช้การเชื่อมต่อ UDP บน KingClient

 // 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 ( ) ;

การใช้การเชื่อมต่อ RUDP บน KingServer

 // 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 ( ) ;

การใช้การเชื่อมต่อ RUDP บน KingClient

 // 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 ( ) ;

การใช้การเชื่อมต่อ WebSocket บน KingServer

 // 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 ( ) ;

การใช้การเชื่อมต่อ WebSocket บน KingClient

 // 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

การทดสอบการเชื่อมต่อ
นอกจากนี้เรายังทดสอบเฉพาะไลบรารี KingNetwork แบบ Raw โดยกระจายเซิร์ฟเวอร์ 1 เครื่องและไคลเอนต์ 1,000 เครื่อง โดยไคลเอนต์แต่ละเครื่องส่ง 100 ไบต์ 14 ครั้งต่อวินาที และเซิร์ฟเวอร์สะท้อนข้อความเดียวกันกลับไปยังไคลเอนต์แต่ละราย คอมพิวเตอร์ทดสอบ: Acer F 15 พร้อมโปรเซสเซอร์ Intel Core i7 7gen 2,9 GHz และ RAM 32 GB DDR4
ผลการทดสอบ:

ลูกค้า	การใช้งานซีพียู	การใช้งานแรม	แบนด์วิธไคลเอนต์ + เซิร์ฟเวอร์	ผลลัพธ์
64	0.5%	9 ลบ	0.3 เมกะไบต์/วินาที	ผ่านไป
128	1%	10 เมกะไบต์	0.7 เมกะไบต์/วินาที	ผ่านไป
500	18%	18 เมกะไบต์	2~3 เมกะไบต์/วินาที	ผ่านไป
1,000	32%	26 เมกะไบต์	5~6 เมกะไบต์/วินาที	ผ่านไป