C#.NET比较好用的tcp通信模板(服务器端篇)

public class InConnectuser
 {
 public TcpClient client { get; set; }
 public BinaryReader br { get; set; }
 public BinaryWriter bw { get; set; }

 public Guid InUseID { get; set; }
 public bool IfUserLogin=false;

 public Entity.FeeRules obj_enFeeRules = new Entity.FeeRules();
 public Entity.InUse obj_enInUse = new Entity.InUse();
 public Entity.Computer obj_enComputer = new Entity.Computer();
 public Entity.User obj_enUser = new Entity.User();

 public InConnectUser(TcpClient client)
 {
 this.client = client;
 NetworkStream networkstream = client.GetStream();
 br = new BinaryReader(networkstream);
 bw = new BinaryWriter(networkstream);
 }
 public void Close() 
 { 
 br.Close();
 bw.Close();
 client.Close(); 
 }
 }

 //在线用户列表
 private List<TcpHelper.InConnectUser> onlineUserList = new List<TcpHelper.InConnectUser>();
 IPAddress localAddress;
 private const int port = 51888;
 private TcpListener myListener;

 //开启服务器的按钮
 private void button_StartServer_Click(object sender, EventArgs e)
 {
 myListener = new TcpListener(localAddress, port);
 myListener.Start();
 label_status.Text = "开启";
 
 Thread myThread = new Thread(ListenClientConnect);
 myThread.Start();
 //timer1.Enabled = true;
 button_StartServer.Visible = false;
 button_StopServer.Visible = true;
 }
 //关闭服务器的按钮
 private void button_StopServer_Click(object sender, EventArgs e)
 {
 label_status.Text = "关闭";
 //关闭服务器，移除list的用户。
 //for (int i = onlineUserList.Count - 1; i >= 0; i--)
 //{
 // RemoveOnlineUser(onlineUserList[i]);
 //}
 myListener.Stop();
 button_StartServer.Visible = true;
 button_StopServer.Visible = false;
 }

 /// <summary>
 /// 监听连接
 /// </summary>
 private void ListenClientConnect()
 {
 TcpClient newClient = null;
 while (true)
 {
 try
 {
 //停在此处监听连接，如果有新客户端连接就运行下去
 newClient = myListener.AcceptTcpClient();
 }
 catch (Exception)
 {

 break;
 }
 InConnectUser user = new InConnectUser(newClient);
 Thread threadReceive = new Thread(ReceiveData);
 threadReceive.Start(user);
 onlineUserList.Add(user);
 
 }

 }



 /// <summary>
 /// 收消息
 /// </summary>
 /// <param name="UserState"></param>
 private void ReceiveData(object UserState)
 {
 InConnectUser user = (InConnectUser)UserState;
 TcpClient client = user.client;
 MessageInfo receiveObject;

 while (true)
 {
 try
 {
 byte[] bytes = new byte[999];
 //停在此处，networkstream流中有新数据则读出
 int i = user.br.Read(bytes, 0, 999);
 MemoryStream memory = new MemoryStream(bytes);
 BinaryFormatter format = new BinaryFormatter();
 receiveObject = (MessageInfo)format.Deserialize(memory);
 }
 catch (Exception)
 {
 return;
 }
 switch (receiveObject.CommandsTypes)
 {
 case CommandsTypes.RequestHowLong:
 //这里是我处理各种命令的方法，和这个博客的主题无关，就不贴出来了。
 //处理好之后，就在这个方法里面发送回应给对应的客户端，所以一定要有参数user
 // ManagerHowLong(user);
 break;
 case CommandsTypes.RequestUserLogin:
 // ManagerUserLogin(user, receiveObject);
 break;
 case CommandsTypes.RequestUserlogout:
 // ManagerUserLogout(user);
 break;
 case CommandsTypes.RequestLogout:
 //注意这里是return，本意是如果客户端的连接要关闭， 就用跳出循环
 //但是我的是网吧管理，不考虑这种情况，所以就未做处理
 return;
 case CommandsTypes.RequestModPWD:
 // ManagerModPWD(user, receiveObject);
 break;
 case CommandsTypes.RequestMachineLogin:
 // ManagerMachineLogin(user, receiveObject);
 break;

 case CommandsTypes.RequestTalk:
 // ManagerTalk(receiveObject);
 break;

 default:
 break;
 }

 }

 }
 
 /// <summary>
 /// 发消息
 /// </summary>
 /// <param name="user">发给谁</param>
 /// <param name="userSend">发送内容</param>
 private void SendToClient(TcpHelper.InConnectUser user, MessageInfo userSend)
 {
 try
 {
 MemoryStream memory = new MemoryStream();
 BinaryFormatter format = new BinaryFormatter();
 format.Serialize(memory, userSend);
 byte[] bytes = memory.ToArray();

 user.bw.Write(bytes);
 user.bw.Flush();
 
 }
 catch (Exception)
 {
 //发送失败
 }
 }