步步为营-66-Socket通信

2023-08-25 18:06:10

1.0 版本

1.1 服务器端

using System;

using System.Collections.Generic;

using System.Linq;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading.Tasks;

namespace Server_1._0

{

    class Program

    {

        static void Main(string[] args)

        {

            //01 创建对象 关键字new

            Socket stk = new Socket(AddressFamily.InterNetwork,//设置IP地址的类型 为ip4

                SocketType.Stream, //设置传输方式 为流式传输

                ProtocolType.Tcp//设置传输协议 为Tcp

            );

            //02 绑定对象 关键字bind()

            stk.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"), ));

            //03 监听对象 关键字Listen()

            stk.Listen();

            Console.WriteLine("服务器启动成功!");

            //04 接受客户端 关键字Accept()     {证明Accept会阻塞线程}

            Socket client = stk.Accept();

            Console.WriteLine("服务器接受到客户端请求!");

            //05 接受报文 关键字receive

            //05-01 通过字节流传递  定义一个字节数组    {证明Receive也会阻塞线程}

            byte[] bys = new byte[];

            int len = client.Receive(bys);

            Console.WriteLine("服务器接收到报文");

            //06 显示接收到的字节数组

            string str = Encoding.UTF8.GetString(bys, , len);

            Console.WriteLine(str);

            //07 发送消息 关键字 send

            string mes = "已成功接收到你发的消息:<" + str + ">";

            client.Send(Encoding.UTF8.GetBytes(mes));

            Console.ReadKey();

        }

    }

}

Server

1.2 客户端

using System;

using System.Collections.Generic;

using System.Linq;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading.Tasks;

namespace Client_1._0

{

    class Program

    {

        static void Main(string[] args)

        {

            //01 创建socket 关键字new

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

            //02 创建连接 关键字connect

            client.Connect(IPAddress.Parse("127.0.0.1"),);

            Console.WriteLine("与服务器创建连接");

            //03 发送消息 关键字Send

            //03-01 定义字节数组

            byte[] bys = new byte[];

            if (Console.ReadLine() == "")

            {

                bys = Encoding.UTF8.GetBytes("逍遥小天狼");

                client.Send(bys);

                Console.WriteLine("向服务器发送消息!");

            }

           //04 接受消息

            //int len = 0;

            //while ((len = client.Receive(bys))>0)

            //{

            //    string s2 = Encoding.UTF8.GetString(bys, 0, len);

            //    Console.Write(s2);

            //}

            byte [] by = new byte[];

            int len = client.Receive(by);

            Console.WriteLine(Encoding.UTF8.GetString(by,,len));

            Console.ReadKey();

        }

    }

}

Client

步步为营-66-Socket通信

2.0 版本

2.1 服务器

using System;

using System.Collections.Generic;

using System.Linq;

using System.Net;

using System.Net.Sockets;

using System.Runtime.Remoting.Contexts;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

namespace Server_1._0

{

    class Program

    {

        static void Main(string[] args)

        {

            //01 创建对象 关键字new

            Socket stk = new Socket(AddressFamily.InterNetwork,//设置IP地址的类型 为ip4

                SocketType.Stream, //设置传输方式 为流式传输

                ProtocolType.Tcp//设置传输协议 为Tcp

            );

            //02 绑定对象 关键字bind()

            stk.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"), ));

            //03 监听对象 关键字Listen()

            stk.Listen();

            Console.WriteLine("服务器启动成功!");

            #region 旧的代码

            ////04 接受客户端 关键字Accept()     {证明Accept会阻塞线程}

            //Socket client = stk.Accept();

            //Console.WriteLine("服务器接受到客户端请求!");

            ////05 接受报文 关键字receive

            ////05-01 通过字节流传递  定义一个字节数组    {证明Receive也会阻塞线程}

            //byte[] bys = new byte[1024];

            //int len = client.Receive(bys);

            //Console.WriteLine("服务器接收到报文");

            ////06 显示接收到的字节数组

            //string str = Encoding.UTF8.GetString(bys, 0, len);

            //Console.WriteLine(str);

            #endregion

            #region 新的代码 -- 通过 线程解决阻塞问题

            Thread thClient = new Thread((s) =>

            {

                while (true)

                {

                    //04 接受客户端 关键字Accept

                    Socket server = s as Socket;

                    Socket client = server.Accept();

                    //04-01 输出具体连接的客户端

                    Console.WriteLine("---客户端" + client.RemoteEndPoint + "连接");

                    //05 获取报文

                    Thread thReceive = new Thread((c) =>

                    {

                        Socket cClient = c as Socket;

                        byte[] bs = new byte[];

                        int len;

                        while ((len = cClient.Receive(bs)) > )

                        {

                            Console.WriteLine(Encoding.UTF8.GetString(bs, , len));

                        }

                    });

                    thReceive.IsBackground = true;

                    thReceive.Start(client);

                }

            });

            thClient.IsBackground = true;

            thClient.Start(stk);

            #endregion

            //07 发送消息 关键字 send

            //string mes = "已成功接收到你发的消息:<" + str + ">";

           // client.Send(Encoding.UTF8.GetBytes(mes));

            Console.ReadKey();

        }

    }

}

2.2 客户端

using System;

using System.Collections.Generic;

using System.Linq;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading.Tasks;

namespace Client_1._0

{

    class Program

    {

        static void Main(string[] args)

        {

            //01 创建socket 关键字new

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

            //02 创建连接 关键字connect

            client.Connect(IPAddress.Parse("127.0.0.1"),);

            Console.WriteLine("与服务器创建连接");

            //03 发送消息 关键字Send

            //03-01 定义字节数组

            byte[] bys = new byte[];

            string str = string.Empty;

            while ((str = Console.ReadLine()) != "")

            {

                bys = Encoding.UTF8.GetBytes(str);

                client.Send(bys);

                Console.WriteLine("向服务器发送消息!");

            }

           //04 接受消息

            #region 04-01 接受消息01

            //int len = 0;

            //while ((len = client.Receive(bys))>0)

            //{

            //    string s2 = Encoding.UTF8.GetString(bys, 0, len);

            //    Console.Write(s2);

            //}

            #endregion

            #region 04-02 接受消息2

            //byte[] by = new byte[1024];

            //int len = client.Receive(by);

            //Console.WriteLine(Encoding.UTF8.GetString(by, 0, len));

            #endregion

            Console.ReadKey();

        }

    }

}

步步为营-66-Socket通信

3.0 版本  Winfrom程序

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

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 Server_Form

{

    public partial class frmServer : Form

    {

        public frmServer()

        {

            InitializeComponent();

        }

        #region 00 客户端字典

        private Dictionary<string,Socket> dicClient = new Dictionary<string, Socket>( );

        #endregion

        #region 01 启动服务器

        private void button1_Click(object sender, EventArgs e)

        {

            //01 创建连接对象

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

            //02 绑定

            serverSCK.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"),));

            //03 监听

            serverSCK.Listen();

            txtMsg.Text = "服务器启动成功!\r\n";

            //04 接受客户端的线程

            Thread thClient = new Thread((server) =>

            {

                Socket serverSocket = server as Socket;

                //05 接受客户端

                while (true)

                {

                    Socket clientSCK = serverSocket.Accept();

                    txtMsg.Invoke(new Action<string> ( (s) =>

                    {

                        //01 提示连接成功

                        txtMsg.Text += s + "连接成功!\r\n";

                        //02 将客户信息显示到列表中

                        clientList.Invoke(new Action<string>((ip) =>

                        {

                            clientList.Items.Add(ip);

                        }),s);

                        //03 将客户端放入到字典中

                        dicClient.Add(s, clientSCK);

                    }),clientSCK.RemoteEndPoint.ToString());

                    //06 接受客户端传来的报文的线程

                    Thread thReceive = new Thread((clientSocket) =>

                    {

                        Socket concentSocket = clientSocket as Socket;

                        byte[] bys = new byte[];

                        int len = ;

                        while ((len = concentSocket.Receive(bys))>)

                        {

                           //处理请求信息

                            txtMsg.Invoke(new Action<string>((s) =>

                            {

                                txtMsg.Text += s + "\r\n";

                            }),concentSocket.RemoteEndPoint.ToString()+":"+Encoding.UTF8.GetString(bys,,len));

                        }

                    });

                    thReceive.IsBackground = true;

                    thReceive.Start(clientSCK);

                }

            });

            thClient.IsBackground = true;

            thClient.Start(serverSCK);

        }

        #endregion

        #region 06 发送消息

        private void btnSend_Click(object sender, EventArgs e)

        {

            //01 获得连接的客户端的字符串

            string clientKey = clientList.SelectedItem.ToString();

            //02 根据字符串获得客户端

            Socket clientSCK = dicClient[clientKey];

            //03 发送消息

            clientSCK.Send(Encoding.UTF8.GetBytes(txtSendMsg.Text));

        }

        #endregion

    }

}

Server

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

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 Client_Form

{

    public partial class FtmClient : Form

    {

        public FtmClient()

        {

            InitializeComponent();

        }

        #region 00 声明全局变量

        private Socket client;

        #endregion

        #region 01 连接服务器

        private void btnConnect_Click(object sender, EventArgs e)

        {

            //01 创建连接对象

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

            //02 连接

            client.Connect(IPAddress.Parse(txtIP.Text),int.Parse(txtPort.Text));

            txtSendMsg.Text += "与服务器连接成功!\r\n";

            //03 接受响应消息

            Thread thReceive = new Thread((clientSck) =>

            {

                Socket clientRecive = clientSck as Socket;

                byte[] bys = new byte[];

                int len = ;

                while ((len = clientRecive.Receive(bys))>)

                {

                    txtRecMsg.Invoke(new Action<string>(s =>

                    {

                        txtRecMsg.Text += s + "\r\n";

                    }),Encoding.UTF8.GetString(bys,,len));

                }

            });

            thReceive.IsBackground = true;

            thReceive.Start(client);

        }

        #endregion

        #region 02 关闭窗体时清空socket 否则连接会出错

        private void FtmClient_FormClosed(object sender, FormClosedEventArgs e)

        {

            client.Shutdown(SocketShutdown.Both);

            client.Close();

            client.Dispose();

        }

        #endregion

        #region 03 发送消息

        private void btnSend_Click(object sender, EventArgs e)

        {

            //01 判断是否为空

            if (client!= null)

            {

                client.Send(Encoding.UTF8.GetBytes(txtSendMsg.Text));

            }

        }

        #endregion

    }

}

Client

步步为营-66-Socket通信

上一篇：快速体验 Laravel 自带的注册、登录功能


下一篇：iframe 标签自适应高度和宽度