一个简易的聊天程序（Socket）

效果图：

服务端Server代码：

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.IO;using System.Linq;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;using System.Threading.Tasks;using System.Windows.Forms;namespace Socket网络编程_Server{public partial class Form1 : Form{public Form1(){InitializeComponent();}private void btnStart_Click(object sender, EventArgs e){try{//当点击开始监听的时候在服务器端创建一个负责监IP地址跟端口号的SocketSocket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPAddress ip = IPAddress.Any;//创建端口号对象IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));//监听socketWatch.Bind(point);ShowMsg("监听成功");socketWatch.Listen(10);Thread th = new Thread(Listen);th.IsBackground = true;th.Start(socketWatch);}catch{ }}/// <summary>/// 等待客户端的连接并且创建与之通信用的Socket/// </summary>Socket socketSend;void Listen(Object o)//线程所执行的函数，，如果有参数，必须是Object类型{Socket socketWatch = o as Socket;//等待客户端的连接并且创建一个负责通信的Socketwhile (true){try{//负责跟客户端通信的SocketsocketSend = socketWatch.Accept();//将远程连接的客户端的IP地址和Socket存入集合中dicSocket.Add(socketSend.RemoteEndPoint.ToString(),socketSend);//将远程连接的客户端的IP地址和Socket存入到下拉框中cboUsers.Items.Add(socketSend.RemoteEndPoint.ToString());//192.168.11.87：连接成功ShowMsg(socketSend.RemoteEndPoint.ToString() + "：连接成功");//开启一个新线程，不停的接收客户端发来的消息Thread th = new Thread(Recive);th.IsBackground = true;th.Start(socketSend);}catch{ }}}//将远程连接的客户端的IP地址和Socket存入集合中Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();/// <summary>/// 服务器端不停的接收客户端发来的消息/// </summary>/// <param name="o"></param>void Recive(Object o){Socket socketSend = o as Socket;while (true){try{//客户端连接成功后，服务器应该接受客户端发来的信息byte[] buffer = new byte[1024 * 1024 * 2];//实际接收到的有效字节数int r = socketSend.Receive(buffer);if (r == 0){break;}string str = Encoding.UTF8.GetString(buffer, 0, r);ShowMsg(socketSend.RemoteEndPoint + ":" + str);}catch{ }}}void ShowMsg(string str){txtLog.AppendText(str + "\r\n");}private void Form1_Load(object sender, EventArgs e){Control.CheckForIllegalCrossThreadCalls = false;}/// <summary>/// 服务器给客户端发送消息/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnSend_Click(object sender, EventArgs e){try{string str = txtMsg.Text;byte[] buffer = Encoding.UTF8.GetBytes(str);List<byte> list = new List<byte>();list.Add(0);list.AddRange(buffer);//将泛型集合转换为集合byte[] newBuffer = list.ToArray();//获得用户在下拉框总选中的IP地址string ip = cboUsers.SelectedItem.ToString();dicSocket[ip].Send(newBuffer);//socketSend.Send(buffer);}catch{}}/// <summary>/// 选择要发送的文件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnSelect_Click(object sender, EventArgs e){OpenFileDialog ofd = new OpenFileDialog();ofd.Title = "请选择";ofd.InitialDirectory = @"C:\Users\Administrator\Desktop";ofd.Filter = "所有文件|*.*";ofd.ShowDialog();txtPath.Text = ofd.FileName;}private void btnSendFile_Click(object sender, EventArgs e){//获得要发送文件的路径string path = txtPath.Text;using (FileStream fsRead=new FileStream(path,FileMode.Open,FileAccess.Read)){byte[] buffer = new byte[1024 * 1024 * 5];int r = fsRead.Read(buffer, 0, buffer.Length);List<byte> list = new List<byte>();list.Add(1);list.AddRange(buffer);byte[] newBuffer = list.ToArray();dicSocket[cboUsers.SelectedItem.ToString()].Send(newBuffer, 0, r+1, SocketFlags.None);}}/// <summary>/// 发送震动/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnZD_Click(object sender, EventArgs e){byte[] buffer = new byte[1];buffer[0] = 2;dicSocket[cboUsers.SelectedItem.ToString()].Send(buffer);}}}客户端Client代码：

就得加倍付出汗水，赢得场场精彩

相关文章：

你感兴趣的文章：

标签云：