USocket.cs 4.8 KB

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