หน้าแรก>ซอร์สโค้ด CGI>หมวดหมู่อื่นๆ
ดาวน์โหลด

ObjectDeliverer-CSharp

การทดสอบ

แพ็คเกจ NuGet

https://www.nuget.org/packages/ObjectDeliverer/

หากต้องการติดตั้งด้วย NuGet เพียงติดตั้งแพ็คเกจ ObjectDeliverer: 

 Install-Package ObjectDeliverer

คำอธิบาย

ObjectDeliverer เป็นไลบรารีการรับส่งข้อมูลสำหรับ C#

เป็นห้องสมุดในเครือที่มีชื่อเดียวกันสำหรับ UE4

https://github.com/ayumax/ObjectDeliverer

มันมีคุณสมบัติดังต่อไปนี้

  • โปรโตคอลการสื่อสาร กฎการแบ่งข้อมูล วิธีการซีเรียลไลซ์สามารถสลับได้โดยการเปลี่ยนชิ้นส่วน
  • คุณยังสามารถใช้วิธีการซีเรียลไลซ์อ็อบเจ็กต์ของคุณเองได้อีกด้วย

โปรโตคอลการสื่อสาร

สามารถใช้โปรโตคอลต่อไปนี้กับบิวท์อินได้ คุณยังสามารถเพิ่มโปรโตคอลของคุณเองได้

  • เซิร์ฟเวอร์ TCP/IP (เชื่อมต่อกับไคลเอนต์หลายเครื่อง)
  • ไคลเอ็นต์ TCP/IP
  • UDP(ผู้ส่ง)
  • UDP(ตัวรับ)
  • หน่วยความจำที่ใช้ร่วมกัน
  • ตัวเขียน LogFile
  • โปรแกรมอ่าน LogFile

กฎการแบ่งข้อมูล

กฎต่อไปนี้พร้อมใช้งานสำหรับกฎการแยกในตัวของข้อมูลที่ส่งและรับ

  • ขนาดคงที่
    ตัวอย่าง) ในกรณีคงที่ 1024 ไบต์ ความยาวคงที่

  • ส่วนหัว(ขนาดลำตัว) + ลำตัว
    ตัวอย่าง) เมื่อพื้นที่ขนาด 4 ไบต์
    ขนาดและร่างกาย

  • แยกตามสัญลักษณ์เทอร์มินัล
    ตัวอย่าง) เมื่อ 0x00 เป็นจุดสิ้นสุด ยุติ

วิธีการทำให้เป็นอนุกรม

  • ไบต์อาร์เรย์
  • สตริง UTF-8
  • วัตถุ (Json)

เริ่มต้นอย่างรวดเร็ว

สร้าง ObjectDelivererManager และสร้างเส้นทางการสื่อสารต่างๆ โดยส่ง "Communication Protocol", "Packet Split Rule" และ "Serialization Method" ไปยังอาร์กิวเมนต์ของวิธี StartAsync 

 // Create an ObjectDelivererManager
var deliverer = new ObjectDelivererManager < string > ( ) ;

// Watching for connection events
deliverer . Connected . Subscribe ( async x =>
{
    Console . WriteLine ( "connected" ) ;

    // Sending data to a connected party
    await deliverer . SendAsync ( new byte [ ] { 0x00 , 0x12 } ) ;
    await deliverer . SendAsync ( new byte [ ] { 0x00 , 0x12 , 0x23 } ) ;
} ) ;

// Watching for disconnection events
deliverer . Disconnected . Subscribe ( x => Console . WriteLine ( "disconnected" ) ) ;
	    
// Watching for incoming events
deliverer . ReceiveData . Subscribe ( x => 
{
    Console . WriteLine ( $ "received buffer length = { x . Buffer . Length } " ) ;
    Console . WriteLine ( $ "received message = { x . Message } " ) ;
} ) ;

// Start the ObjectDelivererManager
await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ,
    new DeliveryBoxString ( ) ) ;

เปลี่ยนโปรโตคอลการสื่อสาร

คุณสามารถสลับไปใช้โปรโตคอลการสื่อสารต่างๆ ได้โดยการเปลี่ยนโปรโตคอลที่ส่งผ่านไปยังวิธี StartAsync 

 // TCP/IP Client
await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// TCP/IP Server
await deliverer . StartAsync (
    new ProtocolTcpIpServer ( ) { ListenPort = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// UDP Sender
await deliverer . StartAsync (
    new ProtocolUdpSocketSender ( ) { DestinationIpAddress = "127.0.0.1" , DestinationPort = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// UDP Receiver
await deliverer . StartAsync (
    new ProtocolUdpSocketReceiver ( ) { BoundPort = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// SharedMemory
await deliverer . StartAsync (
    new ProtocolSharedMemory ( ) { SharedMemoryName = "SharedMemory" , SharedMemorySize = 1024 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// Log File Writer
await deliverer . StartAsync (
    new ProtocolLogWriter ( ) { FilePath = @"C:logcomlog.txt" } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// Log File Reader
await deliverer . StartAsync (
    new ProtocolLogReader ( ) { FilePath = @"C:logcomlog.txt" } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

การเปลี่ยนแปลงกฎการแบ่งข้อมูล

คุณสามารถเปลี่ยนกฎการแยกแพ็คเก็ตได้อย่างง่ายดาย 

 // FixedSize
await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ) ;

// Header(BodySize) + Body
await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleSizeBody ( ) { SizeLength = 4 , SizeBufferEndian = ECNBufferEndian . Big } ) ;

// Split by terminal symbol
await deliverer . StartAsync (
        new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
        new PacketRuleTerminate ( ) { Terminate = new byte [ ] { 0xFE , 0xFF } } ) ;

// Nodivision
await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleNodivision ( ) ) ;

การเปลี่ยนแปลงวิธีการทำให้เป็นอนุกรม

การใช้ DeliveryBox ช่วยให้สามารถส่งและรับข้อมูลที่ไม่ใช่ไบนารี่ได้ (สตริงอักขระและอ็อบเจ็กต์) 

 // UTF-8 string
var deliverer = new ObjectDelivererManager < string > ( ) ;

await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleFixedLength ( ) { FixedSize = 10 } ,
    new DeliveryBoxString ( ) ) ;

deliverer . ReceiveData . Subscribe ( x => Console . WriteLine ( x . Message ) ) ;

await deliverer . SendMessageAsync ( "ABCDEFG" ) ; 
 // Object
public class SampleObj
{
    public int Prop { get ; set ; }
    public string StringProp { get ; set ; }

    public string Hoge ( ) => $ " { Prop } _ { StringProp } " ;
}

var deliverer = new ObjectDelivererManager < SampleObj > ( ) ;

await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleSizeBody ( ) { SizeLength = 4 , SizeBufferEndian = ECNBufferEndian . Big } ,
    new DeliveryBoxObjectJson < SampleObj > ( ) ) ;

deliverer . ReceiveData . Subscribe ( x => Console . WriteLine ( x . Message . Hoge ( ) ) ) ;

var sampleObj = new SampleObj ( ) { Prop = 1 , StringProp = "abc" } ;
await deliverer . SendMessageAsync ( sampleObj ) ;

การสร้าง DeliveryBox แบบกำหนดเอง

คุณสามารถสร้าง DeliveryBox ด้วยวิธีซีเรียลไลซ์ของคุณเองได้

ตัวอย่าง) เมื่อใช้ซีเรียลไลเซอร์โดยใช้ MessagePack (https://github.com/neuecc/MessagePack-CSharp) 

 [ MessagePackObject ]
public class SampleObj2
{
    [ Key ( 0 ) ]
    public int Prop { get ; set ; }

    [ Key ( 1 ) ]
    public string StringProp { get ; set ; }

    public string Hoge ( ) => $ " { Prop } _ { StringProp } " ;
}

// Definition of DeliveryBox using MessagePack
public class ObjectDeliveryBoxUsingMessagePack < T > : IDeliveryBox < T >
{
    public override ReadOnlyMemory < byte > MakeSendBuffer ( T message ) => MessagePackSerializer . Serialize ( message ) ;

    public override T BufferToMessage ( ReadOnlyMemory < byte > buffer ) => MessagePackSerializer . Deserialize < T > ( buffer ) ;
}

var deliverer = new ObjectDelivererManager < SampleObj2 > ( ) ;

await deliverer . StartAsync (
    new ProtocolTcpIpClient ( ) { IpAddress = "127.0.0.1" , Port = 9013 } ,
    new PacketRuleSizeBody ( ) { SizeLength = 4 , SizeBufferEndian = ECNBufferEndian . Big } ,
    new ObjectDeliveryBoxUsingMessagePack < SampleObj2 > ( ) ) ;

deliverer . ReceiveData . Subscribe ( x => Console . WriteLine ( x . Message . Hoge ( ) ) ) ;

var sampleObj = new SampleObj2 ( ) { Prop = 1 , StringProp = "abc" } ;
await deliverer . SendMessageAsync ( sampleObj ) ;
ขยาย
ข้อมูลเพิ่มเติม
แอปที่เกี่ยวข้อง
แนะนำสำหรับคุณ
ข้อมูลที่เกี่ยวข้อง ทั้งหมด