分享一个C#编写简单的聊天程序(详细介绍)

public struct Message {
 private readonly string userName;
 private readonly string content;
 private readonly DateTime postDate;

 public Message(string userName, string content) {
  this.userName = userName;
  this.content = content;
  this.postDate = DateTime.Now;
 }

 public Message(string content) : this("System", content) { }

 public string UserName {
  get { return userName; }
 }

 public string Content {
  get { return content; }
 }

 public DateTime PostDate {
  get { return postDate; }
 }

 public override string ToString() {
  return String.Format("{0}[{1}]：rn{2}rn", userName, postDate, content);
 }
 }

public interface IMessageSender {
 bool Connect(IPAddress ip, int port); // 连接到服务端
 bool SendMessage(Message msg);  // 发送用户
 void SignOut();     // 注销系统
}

public delegate void MessageReceivedEventHandler(string msg); 
 public delegate void ClientConnectedEventHandler(IPEndPoint endPoint);
 public delegate void ConnectionLostEventHandler(string info);

public interface IMessageReceiver {
 event MessageReceivedEventHandler MessageReceived; // 接收到发来的消息
 event ConnectionLostEventHandler ClientLost;  // 远程主动断开连接
 event ClientConnectedEventHandler ClientConnected; // 远程连接到了本地
 void StartListen();  // 开始侦听端口
 void StopListen();  // 停止侦听端口
}

public class Talker {
 private IMessageReceiver receiver;
 private IMessageSender sender;

 public Talker(IMessageReceiver receiver, IMessageSender sender) {
  this.receiver = receiver;
  this.sender = sender;
 }
 }

public class MessageSender : IMessageSender {

 TcpClient client;
 Stream streamToServer;

 // 连接至远程
 public bool Connect(IPAddress ip, int port) {
  try {
  client = new TcpClient();
  client.Connect(ip, port);
  streamToServer = client.GetStream(); // 获取连接至远程的流
  return true;
  } catch {
  return false;
  }
 }

 // 发送消息
 public bool SendMessage(Message msg) {
  try {
  lock (streamToServer) {
   byte[] buffer = Encoding.Unicode.GetBytes(msg.ToString());
   streamToServer.Write(buffer, 0, buffer.Length);
   return true;
  }
  } catch {
  return false;
  }
 }

 // 注销
 public void SignOut() {
  if (streamToServer != null)
  streamToServer.Dispose();
  if (client != null)
  client.Close();
 }
 }

public delegate void PortNumberReadyEventHandler(int portNumber);

 public class MessageReceiver : IMessageReceiver {

 public event MessageReceivedEventHandler MessageReceived;
 public event ConnectionLostEventHandler ClientLost;
 public event ClientConnectedEventHandler ClientConnected;

 // 当端口号Ok的时候调用 -- 需要告诉用户界面使用了哪个端口号在侦听
 // 这里是业务上体现不出来，在实现中才能体现出来的
 public event PortNumberReadyEventHandler PortNumberReady;

 private Thread workerThread;
 private TcpListener listener;

 public MessageReceiver() {
  ((IMessageReceiver)this).StartListen();
 }

 // 开始侦听：显示实现接口
 void IMessageReceiver.StartListen() {
  ThreadStart start = new ThreadStart(ListenThreadMethod);
  workerThread = new Thread(start);
  workerThread.IsBackground = true;
  workerThread.Start();
 }

 // 线程入口方法
 private void ListenThreadMethod() {
  IPAddress localIp = IPAddress.Parse("127.0.0.1");
  listener = new TcpListener(localIp, 0);
  listener.Start();

  // 获取端口号
 IPEndPoint endPoint = listener.LocalEndpoint as IPEndPoint;
  int portNumber = endPoint.Port;
  if (PortNumberReady != null) {
  PortNumberReady(portNumber); // 端口号已经OK，通知用户界面
 }

  while (true) {
  TcpClient remoteClient;
  try {
   remoteClient = listener.AcceptTcpClient();
  } catch {
   break;
  }
  if (ClientConnected != null) {
   // 连接至本机的远程端口
  endPoint = remoteClient.Client.RemoteEndPoint as IPEndPoint;
   ClientConnected(endPoint); // 通知用户界面远程客户连接
  }

  Stream streamToClient = remoteClient.GetStream();
  byte[] buffer = new byte[8192];

  while (true) {
   try {
   int bytesRead = streamToClient.Read(buffer, 0, 8192);
   if (bytesRead == 0) {
    throw new Exception("客户端已断开连接");
   }
   string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead);

   if (MessageReceived != null) {
    MessageReceived(msg); // 已经收到消息
   }
   } catch (Exception ex) {
   if (ClientLost != null) {
    ClientLost(ex.Message); // 客户连接丢失
   break;   // 退出循环
   }
   }
  }
  }
 }

 // 停止侦听端口
 public void StopListen() {
  try {
  listener.Stop();
  listener = null;
  workerThread.Abort();
  } catch { }
 }
 }

public class Talker {
 private IMessageReceiver receiver;
 private IMessageSender sender;

 public Talker(IMessageReceiver receiver, IMessageSender sender) {
  this.receiver = receiver;
  this.sender = sender;
 }

 public Talker() {
  this.receiver = new MessageReceiver();
  this.sender = new MessageSender();
 }

 public event MessageReceivedEventHandler MessageReceived {
  add {
  receiver.MessageReceived += value;
  }
  remove {
  receiver.MessageReceived -= value;
  }
 }

 public event ClientConnectedEventHandler ClientConnected {
  add {
  receiver.ClientConnected += value;
  }
  remove {
  receiver.ClientConnected -= value;
  }
 }

 public event ConnectionLostEventHandler ClientLost {
  add {
  receiver.ClientLost += value;
  }
  remove {
  receiver.ClientLost -= value;
  }
 }

 // 注意这个事件
 public event PortNumberReadyEventHandler PortNumberReady {
  add {
  ((MessageReceiver)receiver).PortNumberReady += value;
  }
  remove {
  ((MessageReceiver)receiver).PortNumberReady -= value;
  }
 }
  

 // 连接远程 - 使用主机名
 public bool ConnectByHost(string hostName, int port) {
  IPAddress[] ips = Dns.GetHostAddresses(hostName);
  return sender.Connect(ips[0], port);
 }

 // 连接远程 - 使用IP
 public bool ConnectByIp(string ip, int port) {
  IPAddress ipAddress;
  try {
  ipAddress = IPAddress.Parse(ip);
  } catch {
  return false;
  }
  return sender.Connect(ipAddress, port);
 }


 // 发送消息
 public bool SendMessage(Message msg) {
  return sender.SendMessage(msg);
 }

 // 释放资源，停止侦听
 public void Dispose() {
  try {
  sender.SignOut();
  receiver.StopListen();
  } catch {
  }
 }

 // 注销
 public void SignOut() {
  try {
  sender.SignOut();
  } catch {
  }
 }
 }

public partial class PrimaryForm : Form {

 private Talker talker;
 private string userName;

 public PrimaryForm(string name) {
  InitializeComponent();
  userName = lbName.Text = name;
  this.talker = new Talker();
  this.Text = userName + " Talking ...";
  talker.ClientLost +=
  new ConnectionLostEventHandler(talker_ClientLost);
  talker.ClientConnected +=
  new ClientConnectedEventHandler(talker_ClientConnected);
  talker.MessageReceived += 
  new MessageReceivedEventHandler(talker_MessageReceived);
  talker.PortNumberReady +=
  new PortNumberReadyEventHandler(PrimaryForm_PortNumberReady);
 }

 void ConnectStatus() { }
 void DisconnectStatus() { }

 // 端口号OK
 void PrimaryForm_PortNumberReady(int portNumber) {  
  PortNumberReadyEventHandler del = delegate(int port) {
  lbPort.Text = port.ToString();
  };
  lbPort.Invoke(del, portNumber);
 }

 // 接收到消息
 void talker_MessageReceived(string msg) {
  MessageReceivedEventHandler del = delegate(string m) {
  txtContent.Text += m;
  };
  txtContent.Invoke(del, msg);
 }

 // 有客户端连接到本机
 void talker_ClientConnected(IPEndPoint endPoint) {
  ClientConnectedEventHandler del = delegate(IPEndPoint end) {
  IPHostEntry host = Dns.GetHostEntry(end.Address);
  txtContent.Text += 
   String.Format("System[{0}]：rn远程主机{1}连接至本地。rn", DateTime.Now, end);
  };
  txtContent.Invoke(del, endPoint);
 }

 // 客户端连接断开
 void talker_ClientLost(string info) {
  ConnectionLostEventHandler del = delegate(string information) {
  txtContent.Text +=
   String.Format("System[{0}]：rn{1}rn", DateTime.Now, information);
  };
  txtContent.Invoke(del, info);
 }

 // 发送消息
 private void btnSend_Click(object sender, EventArgs e) {
  if (String.IsNullOrEmpty(txtMessage.Text)) {
  MessageBox.Show("请输入内容！");
  txtMessage.Clear();
  txtMessage.Focus();
  return;
  }

  Message msg = new Message(userName, txtMessage.Text);
  if (talker.SendMessage(msg)) {
  txtContent.Text += msg.ToString();
  txtMessage.Clear();
  } else {
  txtContent.Text +=
   String.Format("System[{0}]：rn远程主机已断开连接rn", DateTime.Now);
  DisconnectStatus();
  }
 }


 // 点击连接
 private void btnConnect_Click(object sender, EventArgs e) {

  string host = txtHost.Text;
  string ip = txtHost.Text;
  int port;

  if (String.IsNullOrEmpty(txtHost.Text)) {
  MessageBox.Show("主机名称或地址不能为空");
  }  

  try{
  port = Convert.ToInt32(txtPort.Text);
  }catch{
  MessageBox.Show("端口号不能为空，且必须为数字");
  return;
  }
  
  if (talker.ConnectByHost(host, port)) {
  ConnectStatus();
  txtContent.Text +=
   String.Format("System[{0}]：rn已成功连接至远程rn", DateTime.Now);
  return;
  }
  
  if(talker.ConnectByIp(ip, port)){
  ConnectStatus();
  txtContent.Text +=
   String.Format("System[{0}]：rn已成功连接至远程rn", DateTime.Now);
  }else{
  MessageBox.Show("远程主机不存在，或者拒绝连接！");
  }  

  txtMessage.Focus();
 }

 // 关闭按钮点按
 private void btnClose_Click(object sender, EventArgs e) {
  try {
  talker.Dispose();
  Application.Exit();
  } catch {
  }
 }

 // 直接点击右上角的叉
 private void PrimaryForm_FormClosing(object sender, FormClosingEventArgs e) {
  try {
  talker.Dispose();
  Application.Exit();
  } catch {
  }
 }

 // 点击注销
 private void btnSignout_Click(object sender, EventArgs e) {
  talker.SignOut();
  DisconnectStatus();
  txtContent.Text += 
  String.Format("System[{0}]：rn已经注销rn",DateTime.Now);
 }

 private void btnClear_Click(object sender, EventArgs e) {
  txtContent.Clear();
 }
 }