USocket.cs 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Runtime.InteropServices;
  4. using System.Threading.Tasks;
  5. using Common.Network;
  6. namespace UNet
  7. {
  8. internal sealed class USocket: IDisposable
  9. {
  10. private IntPtr peerPtr;
  11. private readonly Queue<byte[]> recvQueue = new Queue<byte[]>();
  12. public Action<ENetEvent> Connected { get; set; }
  13. public Action<ENetEvent> Received { get; private set; }
  14. public Action<ENetEvent> Disconnect { get; private set; }
  15. public Action<int> Error { get; set; }
  16. private void Dispose(bool disposing)
  17. {
  18. if (this.peerPtr == IntPtr.Zero)
  19. {
  20. return;
  21. }
  22. NativeMethods.EnetPeerReset(this.peerPtr);
  23. this.peerPtr = IntPtr.Zero;
  24. }
  25. public USocket(IntPtr peerPtr)
  26. {
  27. this.peerPtr = peerPtr;
  28. }
  29. ~USocket()
  30. {
  31. this.Dispose(false);
  32. }
  33. public void Dispose()
  34. {
  35. this.Dispose(true);
  36. GC.SuppressFinalize(this);
  37. }
  38. public IntPtr PeerPtr
  39. {
  40. get
  41. {
  42. return this.peerPtr;
  43. }
  44. }
  45. private ENetPeer Struct
  46. {
  47. get
  48. {
  49. if (this.peerPtr == IntPtr.Zero)
  50. {
  51. return new ENetPeer();
  52. }
  53. ENetPeer peer = (ENetPeer) Marshal.PtrToStructure(this.peerPtr, typeof (ENetPeer));
  54. return peer;
  55. }
  56. set
  57. {
  58. Marshal.StructureToPtr(value, this.peerPtr, false);
  59. }
  60. }
  61. public string RemoteAddress
  62. {
  63. get
  64. {
  65. ENetPeer peer = this.Struct;
  66. return peer.Address.Host + ":" + peer.Address.Port;
  67. }
  68. }
  69. public void Ping()
  70. {
  71. NativeMethods.EnetPeerPing(this.peerPtr);
  72. }
  73. public void ConfigureThrottle(uint interval, uint acceleration, uint deceleration)
  74. {
  75. NativeMethods.EnetPeerThrottleConfigure(this.peerPtr, interval, acceleration, deceleration);
  76. }
  77. public void SendAsync(byte[] data, byte channelID = 0, PacketFlags flags = PacketFlags.Reliable)
  78. {
  79. UPacket packet = new UPacket(data, flags);
  80. NativeMethods.EnetPeerSend(this.peerPtr, channelID, packet.PacketPtr);
  81. // enet_peer_send函数会自动删除packet,设置为0,防止Dispose或者析构函数再次删除
  82. packet.PacketPtr = IntPtr.Zero;
  83. }
  84. public Task<byte[]> RecvAsync()
  85. {
  86. var tcs = new TaskCompletionSource<byte[]>();
  87. // 如果有缓存的包,从缓存中取
  88. if (this.recvQueue.Count > 0)
  89. {
  90. byte[] bytes = this.recvQueue.Dequeue();
  91. tcs.TrySetResult(bytes);
  92. }
  93. // 没有缓存封包,设置回调等待
  94. else
  95. {
  96. this.Received = eEvent =>
  97. {
  98. if (eEvent.Type == EventType.Disconnect)
  99. {
  100. tcs.TrySetException(new UException("socket disconnected in receive"));
  101. }
  102. using (UPacket packet = new UPacket(eEvent.Packet))
  103. {
  104. byte[] bytes = packet.Bytes;
  105. tcs.TrySetResult(bytes);
  106. }
  107. };
  108. }
  109. return tcs.Task;
  110. }
  111. public Task<bool> DisconnectAsync(uint data = 0)
  112. {
  113. NativeMethods.EnetPeerDisconnect(this.peerPtr, data);
  114. // EnetPeerDisconnect会reset Peer,这里设置为0,防止再次Dispose
  115. this.peerPtr = IntPtr.Zero;
  116. var tcs = new TaskCompletionSource<bool>();
  117. this.Disconnect = eEvent => tcs.TrySetResult(true);
  118. return tcs.Task;
  119. }
  120. public Task<bool> DisconnectLaterAsync(uint data = 0)
  121. {
  122. NativeMethods.EnetPeerDisconnectLater(this.peerPtr, data);
  123. // EnetPeerDisconnect会reset Peer,这里设置为0,防止再次Dispose
  124. this.peerPtr = IntPtr.Zero;
  125. var tcs = new TaskCompletionSource<bool>();
  126. this.Disconnect = eEvent => tcs.TrySetResult(true);
  127. return tcs.Task;
  128. }
  129. public void DisconnectNow(uint data)
  130. {
  131. NativeMethods.EnetPeerDisconnectNow(this.peerPtr, data);
  132. // EnetPeerDisconnect会reset Peer,这里设置为0,防止再次Dispose
  133. this.peerPtr = IntPtr.Zero;
  134. }
  135. internal void OnConnected(ENetEvent eNetEvent)
  136. {
  137. if (this.Connected == null)
  138. {
  139. return;
  140. }
  141. Action<ENetEvent> localConnected = this.Connected;
  142. this.Connected = null;
  143. // 此调用将让await ConnectAsync返回,所以null必须在此之前设置
  144. localConnected(eNetEvent);
  145. }
  146. internal void OnReceived(ENetEvent eNetEvent)
  147. {
  148. // 如果应用层还未调用readasync则将包放到缓存队列
  149. if (this.Received == null)
  150. {
  151. using (UPacket packet = new UPacket(eNetEvent.Packet))
  152. {
  153. byte[] bytes = packet.Bytes;
  154. this.recvQueue.Enqueue(bytes);
  155. }
  156. }
  157. else
  158. {
  159. Action<ENetEvent> localReceived = this.Received;
  160. this.Received = null;
  161. // 此调用将让await ReadAsync返回,所以null必须在此之前设置
  162. localReceived(eNetEvent);
  163. }
  164. }
  165. internal void OnDisconnect(ENetEvent eNetEvent)
  166. {
  167. if (this.Disconnect == null)
  168. {
  169. return;
  170. }
  171. Action<ENetEvent> localDisconnect = this.Disconnect;
  172. this.Disconnect = null;
  173. localDisconnect(eNetEvent);
  174. }
  175. }
  176. }