TSocket.cs 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231
  1. using System;
  2. using System.Net;
  3. using System.Net.Sockets;
  4. using System.Threading.Tasks;
  5. using Common.Logger;
  6. namespace TNet
  7. {
  8. public class TSocket
  9. {
  10. private readonly IPoller poller;
  11. private Socket socket;
  12. private readonly SocketAsyncEventArgs innArgs = new SocketAsyncEventArgs();
  13. private readonly SocketAsyncEventArgs outArgs = new SocketAsyncEventArgs();
  14. public TSocket(IPoller poller)
  15. {
  16. this.poller = poller;
  17. this.socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  18. this.innArgs.Completed += this.OnComplete;
  19. this.outArgs.Completed += this.OnComplete;
  20. }
  21. public IPoller Poller
  22. {
  23. get
  24. {
  25. return this.poller;
  26. }
  27. }
  28. public string RemoteAddress
  29. {
  30. get
  31. {
  32. return ((IPEndPoint)socket.RemoteEndPoint).Address + ":" + ((IPEndPoint)socket.RemoteEndPoint).Port;
  33. }
  34. }
  35. public Socket Socket
  36. {
  37. get
  38. {
  39. return this.socket;
  40. }
  41. }
  42. protected virtual void Dispose(bool disposing)
  43. {
  44. if (this.socket == null)
  45. {
  46. return;
  47. }
  48. if (disposing)
  49. {
  50. this.socket.Dispose();
  51. }
  52. this.socket = null;
  53. }
  54. ~TSocket()
  55. {
  56. this.Dispose(false);
  57. }
  58. public void Dispose()
  59. {
  60. Dispose(true);
  61. GC.SuppressFinalize(this);
  62. }
  63. public void Bind(string host, int port)
  64. {
  65. this.socket.Bind(new IPEndPoint(IPAddress.Parse(host), port));
  66. }
  67. public void Listen(int backlog)
  68. {
  69. this.socket.Listen(backlog);
  70. }
  71. private void OnComplete(object sender, SocketAsyncEventArgs e)
  72. {
  73. Action action;
  74. switch (e.LastOperation)
  75. {
  76. case SocketAsyncOperation.Accept:
  77. action = () => OnAcceptComplete(e);
  78. break;
  79. case SocketAsyncOperation.Connect:
  80. action = () => OnConnectComplete(e);
  81. break;
  82. case SocketAsyncOperation.Disconnect:
  83. action = () => OnDisconnectComplete(e);
  84. break;
  85. case SocketAsyncOperation.Receive:
  86. action = () => OnRecvComplete(e);
  87. break;
  88. case SocketAsyncOperation.Send:
  89. action = () => OnSendComplete(e);
  90. break;
  91. default:
  92. throw new ArgumentOutOfRangeException();
  93. }
  94. this.poller.Add(action);
  95. }
  96. public Task<bool> ConnectAsync(string host, int port)
  97. {
  98. var tcs = new TaskCompletionSource<bool>();
  99. this.outArgs.UserToken = tcs;
  100. this.outArgs.RemoteEndPoint = new IPEndPoint(IPAddress.Parse(host), port);
  101. if (!this.socket.ConnectAsync(this.outArgs))
  102. {
  103. OnConnectComplete(this.outArgs);
  104. }
  105. return tcs.Task;
  106. }
  107. private static void OnConnectComplete(SocketAsyncEventArgs e)
  108. {
  109. var tcs = (TaskCompletionSource<bool>)e.UserToken;
  110. e.UserToken = null;
  111. if (e.SocketError != SocketError.Success)
  112. {
  113. tcs.SetException(new Exception(string.Format("socket error: {0}", e.SocketError)));
  114. return;
  115. }
  116. tcs.SetResult(true);
  117. }
  118. public Task<bool> AcceptAsync(TSocket accpetSocket)
  119. {
  120. var tcs = new TaskCompletionSource<bool>();
  121. this.innArgs.UserToken = tcs;
  122. this.innArgs.AcceptSocket = accpetSocket.socket;
  123. if (!this.socket.AcceptAsync(this.innArgs))
  124. {
  125. OnAcceptComplete(this.innArgs);
  126. }
  127. return tcs.Task;
  128. }
  129. private static void OnAcceptComplete(SocketAsyncEventArgs e)
  130. {
  131. var tcs = (TaskCompletionSource<bool>)e.UserToken;
  132. e.UserToken = null;
  133. if (e.SocketError != SocketError.Success)
  134. {
  135. tcs.SetException(new Exception(string.Format("socket error: {0}", e.SocketError)));
  136. return;
  137. }
  138. tcs.SetResult(true);
  139. }
  140. public Task<int> RecvAsync(byte[] buffer, int offset, int count)
  141. {
  142. var tcs = new TaskCompletionSource<int>();
  143. this.innArgs.UserToken = tcs;
  144. this.innArgs.SetBuffer(buffer, offset, count);
  145. if (!this.socket.ReceiveAsync(this.innArgs))
  146. {
  147. OnRecvComplete(this.innArgs);
  148. }
  149. return tcs.Task;
  150. }
  151. private static void OnRecvComplete(SocketAsyncEventArgs e)
  152. {
  153. Log.Debug("OnRecvComplete: " + e.BytesTransferred);
  154. var tcs = (TaskCompletionSource<int>)e.UserToken;
  155. e.UserToken = null;
  156. if (e.SocketError != SocketError.Success)
  157. {
  158. tcs.SetException(new Exception(string.Format("socket error: {0}", e.SocketError)));
  159. return;
  160. }
  161. tcs.SetResult(e.BytesTransferred);
  162. }
  163. public Task<int> SendAsync(byte[] buffer, int offset, int count)
  164. {
  165. var tcs = new TaskCompletionSource<int>();
  166. this.outArgs.UserToken = tcs;
  167. this.outArgs.SetBuffer(buffer, offset, count);
  168. if (!this.socket.SendAsync(this.outArgs))
  169. {
  170. OnSendComplete(this.outArgs);
  171. }
  172. return tcs.Task;
  173. }
  174. private static void OnSendComplete(SocketAsyncEventArgs e)
  175. {
  176. var tcs = (TaskCompletionSource<int>)e.UserToken;
  177. e.UserToken = null;
  178. if (e.SocketError != SocketError.Success)
  179. {
  180. tcs.SetException(new Exception(string.Format("socket error: {0}", e.SocketError)));
  181. return;
  182. }
  183. tcs.SetResult(e.BytesTransferred);
  184. }
  185. public Task<bool> DisconnectAsync()
  186. {
  187. var tcs = new TaskCompletionSource<bool>();
  188. this.outArgs.UserToken = tcs;
  189. if (!this.socket.DisconnectAsync(this.outArgs))
  190. {
  191. OnDisconnectComplete(this.outArgs);
  192. }
  193. return tcs.Task;
  194. }
  195. private static void OnDisconnectComplete(SocketAsyncEventArgs e)
  196. {
  197. var tcs = (TaskCompletionSource<bool>)e.UserToken;
  198. e.UserToken = null;
  199. if (e.SocketError != SocketError.Success)
  200. {
  201. tcs.SetException(new Exception(string.Format("socket error: {0}", e.SocketError)));
  202. return;
  203. }
  204. tcs.SetResult(true);
  205. }
  206. }
  207. }