using System;

using System.Collections.Generic;

using System.IO;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

using System.Windows.Forms;

namespace SocketStudy

{

    public partial class Form1 : Form

    {

        public Form1()

        {

            InitializeComponent();

        }

        /// <summary>

        /// 负责通信的socket

        /// </summary>

        Socket socketSend;

        /// <summary>

        /// 负责监听Socket

        /// </summary>

        Socket socket;

        /// <summary>

        /// 存放连接的socket

        /// </summary>

        Dictionary<string, Socket> dictionary = new Dictionary<string, Socket>();

        /// <summary>

        /// 开始监听

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void button1_Click(object sender, EventArgs e)

        {

            //创建监听的socket,

            //SocketType.Stream 流式对应tcp协议

            //Dgram,数据报对应UDP协议

            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //创建IP地址和端口号

            IPAddress ip = IPAddress.Any;//IPAddress.Parse(textServerIP.Text);

            int port = Convert.ToInt32(textServerPort.Text);

            IPEndPoint iPEndPoint = new IPEndPoint(ip, port);

            //让负责监听的Socket绑定ip和端口号

            socket.Bind(iPEndPoint);

            ShowLog("监听成功！" + ip + "\t" + port);//打印日志

            //设置监听队列

            socket.Listen(10);//一段时间内可以连接到的服务器的最大数量

            Thread thread = new Thread(Listen);

            thread.IsBackground = true;

            thread.Start(socket);

        }

        /// <summary>

        /// 使用线程来接收数据

        /// </summary>

        /// <param name="o"></param>

        private void Listen(object o)

        {

            Socket socket = o as Socket;

            while(true){

                //负责监听的socket是用来接收客户端连接

                //创建负责通信的socket

                socketSend = socket.Accept();

                dictionary.Add(socketSend.RemoteEndPoint.ToString(), socketSend);

                clientCombo.Items.Add(socketSend.RemoteEndPoint.ToString());

                ShowLog(socketSend.RemoteEndPoint.ToString() + "已连接");

                //开启新线程，接收客户端发来的信息

                Thread th = new Thread(receive);

                th.IsBackground = true;

                th.Start(socketSend);

            }

        }

        //服务器接收客户端传来的消息

        private void receive(object o)

        {

            Socket socketSend = o as Socket;

            while (true)

            {

                try

                {

                    //客户端连接成功后，服务器接收客户端发来的消息

                    byte[] buffer = new byte[1024 * 1024 * 2];//2M大小

                                                              //接收到的有效字节数

                    int length = socketSend.Receive(buffer);

                    if (length == 0)

                    {

                        ShowLog(socketSend.RemoteEndPoint.ToString() + "下线了。");

                        dictionary[socketSend.RemoteEndPoint.ToString()].Shutdown(SocketShutdown.Both);

                        dictionary[socketSend.RemoteEndPoint.ToString()].Disconnect(false);

                        dictionary[socketSend.RemoteEndPoint.ToString()].Close();

                        break;

                    }

                    string str = Encoding.ASCII.GetString(buffer, 0, length);

                    ShowLog(socketSend.RemoteEndPoint.ToString() + "\n\t" + str);

                }

                catch (Exception ex)

                {

                    Console.WriteLine(ex.Message);

                }

            }

        }

        /// <summary>

        /// 日志打印

        /// </summary>

        /// <param name="str"></param>

        private void ShowLog(string str)

        {

            textLog.AppendText(str + "\r\n");

        }

        private void Form1_Load(object sender, EventArgs e)

        {

            //取消对跨线程调用而产生的错误

            Control.CheckForIllegalCrossThreadCalls = false;

        }

        private void sendMsgBtn_Click(object sender, EventArgs e)

        {

            string txt = textMsg.Text;

            byte[] buffer = Encoding.UTF8.GetBytes(txt);

            List<byte> list = new List<byte>();

            list.Add(0); // 0 为 发消息

            list.AddRange(buffer);

            byte[] newBuffer = list.ToArray();

            //socketSend.Send(buffer);

            string ip = clientCombo.SelectedItem.ToString();//获取选中的ip地址

            Socket socketsend=dictionary[ip];

            socketsend.Send(newBuffer);

        }

        private void selectBtn_Click(object sender, EventArgs e)

        {

            OpenFileDialog fileDialog = new OpenFileDialog();

            fileDialog.InitialDirectory=@"D:";

            fileDialog.Title="选择文件";

            fileDialog.Filter = "所有文件|*.*";

            fileDialog.ShowDialog();

            pathTxt.Text = fileDialog.FileName;

        }

        /// <summary>

        /// 发文件，

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void sendFileBtn_Click(object sender, EventArgs e)

        {

            string path = pathTxt.Text;

            FileStream fileStream = new FileStream(path,FileMode.Open,FileAccess.Read);

            byte[] buffer = new byte[1024*1024*3];

            buffer[0] = 1;// 1 为发文件的标志位

            int length = fileStream.Read(buffer, 1, buffer.Length-1);

            fileStream.Close();

            string ip = clientCombo.SelectedItem.ToString();//获取选中的ip地址

            Socket socketsend = dictionary[ip];

            socketsend.Send(buffer,0, length+1, SocketFlags.None);

        }

        /// <summary>

        /// 抖一抖

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void shockBtn_Click(object sender, EventArgs e)

        {

            byte[] buffer = new byte[1];

            buffer[0] = 2;// 2 为抖一抖

            string ip = clientCombo.SelectedItem.ToString();//获取选中的ip地址

            Socket socketsend = dictionary[ip];

            socketsend.Send(buffer);

        }

        /// <summary>

        /// 关闭前关闭socket

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)

        {

            try

            {

                socket.Shutdown(SocketShutdown.Both);

                socket.Disconnect(false);

                socket.Close();

            }

            catch

            {

                socket.Close();

            }

        }

    }

}

using System.IO;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

using System.Windows.Forms;

namespace Client

{

    public partial class Form1 : Form

    {

        public Form1()

        {

            InitializeComponent();

        }

        Socket socket;
　　　　　　//连接

        private void connectBtn_Click(object sender, EventArgs e)

        {

            try

            {

                //创建负责通信的socket

                socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

                //地址、端口

                IPAddress ip = IPAddress.Parse(ipText.Text);

                int serverPort = Convert.ToInt32(portText.Text);

                IPEndPoint port = new IPEndPoint(ip, serverPort);

                //连接到服务器

                socket.Connect(port);

                ShowLog("已连接");

                //启动接收数据线程

                Thread th = new Thread(receive);

                th.IsBackground = true;

                th.Start();

            }

            catch { }

        }
　　　　//日志

        private void ShowLog(string str)

        {

            textLog.AppendText(str + "\r\n");

        }

        /// <summary>

        /// 发消息

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void sendMsgBtn_Click(object sender, EventArgs e)

        {

            try

            {

                string txt = sendMsg.Text;

                byte[] buffer = Encoding.ASCII.GetBytes(txt);//ascii编码

                socket.Send(buffer);

            }

            catch { }

        }

　　　　
　　　　//接收消息


        private void receive()

        {

            while (true)

            {

                try

                {

                    byte[] buffer = new byte[1024 * 1024 * 2];

                    int length = socket.Receive(buffer);

                    if (length == 0)

                    {

                        break;

                    }

                    if (buffer[0] == 0)

                    {

                        string txt = Encoding.UTF8.GetString(buffer, 1, length-1);

                        ShowLog(socket.RemoteEndPoint + ":\r\t" + txt);

                    }else if (buffer[0] == 1)

                    {

                        SaveFileDialog saveFileDialog = new SaveFileDialog();

                        saveFileDialog.InitialDirectory = @"E:\";

                        saveFileDialog.Title = "饿了吃什么";

                        saveFileDialog.Filter = "所有文件 | *.*";

                        saveFileDialog.ShowDialog(this);

                        string path = saveFileDialog.FileName;

                        FileStream fileStreamWrite = new FileStream(path, FileMode.OpenOrCreate, FileAccess.Write);

                        fileStreamWrite.Write(buffer,1,length-1);

                        fileStreamWrite.Close();

                        MessageBox.Show("保存成功");

                    }else if (buffer[0] == 2)

                    {

                        ZD();

                    }

                }

                catch { }

            }

        }

　　　　　　//震动

        private void ZD()

        {

            for(int i=0;i<20;i++){

                if (i%2==0)

                {

                    this.Location = new System.Drawing.Point(500, 500);

                }

                else

                {

                    this.Location = new System.Drawing.Point(530, 530);

                }

                Thread.Sleep(20);

            }

        }

　　　　//取消跨线程检查

        private void Form1_Load(object sender, EventArgs e)

        {

            Control.CheckForIllegalCrossThreadCalls = false;

        }

　　　　//关闭前关掉socket

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)

        {

            socket.Disconnect(false);

            socket.Close();

        }

　　　　　　//断开连接

        private void button1_Click(object sender, EventArgs e)

        {

            if (socket !=null)

            {

                socket.Disconnect(false);

            }

        }

    }

}