服务端：
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Net.Sockets; using System.Net; using System.Threading; using System.IO; namespace 服务端 { public partial class Form1 : Form { public Form1() { InitializeComponent(); Control.CheckForIllegalCrossThreadCalls = false; } /// <summary> /// 监听socket /// </summary> Socket socketListen; Dictionary<string, Socket> dirSocket = new Dictionary<string, Socket>(); //户务端监听客户端连接情况 private void btnListen_Click(object sender, EventArgs e) { try { socketListen = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPAddress ip = IPAddress.Any; IPEndPoint point = new IPEndPoint(ip, Int32.Parse(txtPort.Text)); socketListen.Bind(point); socketListen.Listen(10); showMsg("监听成功"); Thread thread = new Thread(Listen); thread.IsBackground = true; thread.Start(); } catch (Exception) { } } /// <summary> /// 监听客服端 /// </summary> void Listen() { try { //不断的监听客户端 while (true) { Socket socket = socketListen.Accept(); showMsg(socket.RemoteEndPoint.ToString() + ":连接成功"); cbList.Items.Add(socket.RemoteEndPoint.ToString()); dirSocket.Add(socket.RemoteEndPoint.ToString(), socket); //不断接受客户端信息 Thread thread = new Thread(Receive); thread.IsBackground = true; thread.Start(socket); } } catch (Exception) { } } /// <summary> /// 接收客服端的信息 /// </summary> /// <param name="o"></param> void Receive(object o) { try { Socket socketSend = o as Socket; byte[] buffer = new byte[1024 * 1024 * 2]; while (true) { int r = socketSend.Receive(buffer); if (r <= 0) { break; } string result = Encoding.UTF8.GetString(buffer, 0, r); showMsg(socketSend.RemoteEndPoint.ToString() + ":" + result); } } catch (Exception) { } } /// <summary> /// 显示信息 /// </summary> /// <param name="msg"></param> void showMsg(string msg) { txtLog.AppendText(msg + " "); } /// <summary> /// 发送信息 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnSendMsg_Click(object sender, EventArgs e) { string ipAddress = cbList.SelectedItem.ToString(); if (string.IsNullOrEmpty(ipAddress)) { return; } string msg = this.txtMsg.Text.Trim(); byte[] msgBytes = Encoding.UTF8.GetBytes(msg); byte[] newArray = GetByteArray(0,msgBytes); dirSocket[ipAddress].Send(newArray); } /// <summary> /// 选择文件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnSelectFile_Click(object sender, EventArgs e) { OpenFileDialog ofd = new OpenFileDialog(); if (ofd.ShowDialog() == DialogResult.OK) { this.txtPath.Text = ofd.FileName; } } /// <summary> /// 发送文件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnSendFile_Click(object sender, EventArgs e) { string ipAddress = cbList.SelectedItem.ToString(); if (string.IsNullOrEmpty(ipAddress)) { return; } string filename = this.txtPath.Text.Trim(); byte[] msgBytes = File.ReadAllBytes(filename); byte[] newArray = GetByteArray(1, msgBytes); dirSocket[ipAddress].Send(newArray); } /// <summary> /// 发送抖屏 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnMoveScreen_Click(object sender, EventArgs e) { string ipAddress = cbList.SelectedItem.ToString(); if (string.IsNullOrEmpty(ipAddress)) { return; } byte[] newArray = new byte[1] { 2 }; dirSocket[ipAddress].Send(newArray); } /// <summary> /// 处理发送byte数据 /// </summary> /// <param name="type"></param> /// <param name="array"></param> /// <returns></returns> private byte[] GetByteArray(int type,byte[] array) { byte[] newArray = new byte[array.Length+1]; array.CopyTo(newArray, 1); switch (type) { case 0: newArray[0] = 0; break; case 1: newArray[0] = 1; break; default: newArray[0] = 2; break; } return newArray; } } }
客服端：
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Net.Sockets; using System.Net; using System.Threading; using System.IO; namespace 客户端 { public partial class Form1 : Form { public Form1() { InitializeComponent(); Control.CheckForIllegalCrossThreadCalls = false; } Socket socket; private void btnListen_Click(object sender, EventArgs e) { try { socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPAddress ip = IPAddress.Parse(txtAddress.Text); IPEndPoint point = new IPEndPoint(ip, Int32.Parse(txtPort.Text)); socket.Connect(point); showMsg("连接服务端成功！！！！"); Thread thread = new Thread(Receive); thread.IsBackground = true; thread.SetApartmentState(ApartmentState.STA); thread.Start(); } catch (Exception ex) { } } void Receive() { try { byte[] buffer = new byte[1024 * 1024 * 2]; while (true) { int r = socket.Receive(buffer); if (r <= 0) break; switch (buffer[0]) { case 0 : //文本内容 GetMsg(buffer, r); break; case 1: //文本文件 GetFile(buffer, r); break; default: //抖屏 GetMoveScreen(); break; } } } catch (Exception) { } } /// <summary> /// 接收内容 /// </summary> /// <param name="array"></param> /// <param name="realLength"></param> void GetMsg(byte[] array,int realLength) { string msg = Encoding.UTF8.GetString(array, 1, realLength-1); showMsg(msg); } /// <summary> /// 接收文件 /// </summary> /// <param name="array"></param> /// <param name="realLength"></param> void GetFile(byte[] array,int realLength) { SaveFileDialog sfd = new SaveFileDialog(); if (sfd.ShowDialog() == DialogResult.OK) { string filename = sfd.FileName; using(FileStream fs = new FileStream(filename,FileMode.Create,FileAccess.ReadWrite)) { fs.Write(array, 1, realLength - 1); } showMsg("文件保存到:"+filename+"成功！！！"); } } Random r = new Random(); /// <summary> /// 抖屏 /// </summary> void GetMoveScreen() { Point startPoint = this.Location; for (int i = 0; i < 200; i++) { this.Location = new Point(startPoint.X + r.Next(20), startPoint.Y + r.Next(20)); } this.Location = startPoint; } /// <summary> /// 显示内容 /// </summary> /// <param name="p"></param> private void showMsg(string p) { textBox1.AppendText(p + " "); } /// <summary> /// 发送内容 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnSend_Click(object sender, EventArgs e) { try { string msg = txtMsg.Text.Trim(); byte[] buffer = Encoding.UTF8.GetBytes(msg); socket.Send(buffer); } catch (Exception) { } } } }
