首页 后端开发 C#.Net教程 C# Socket 线程

C# Socket 线程

Feb 20, 2017 am 11:06 AM

最初的版本是这样的:点击打开链接。但一直没有调好,所以就咨询了一下同事翔哥,最后初步搞定!

客户端代码:


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.Threading;
using System.Net;
using System.Diagnostics;

namespace SocketClient
{
    public partial class Client : Form
    {    
        Socket vsServerSocket;
        Thread vsClientThread;
        string strIP = "127.0.0.1";
        public delegate void PassString(string strMsg);
        int nPort = 9001;
        public Client()
        {
            InitializeComponent();
        }
        public void SetSendData(string strMsg)
        {
            if (tBoxClientSend.InvokeRequired == true)
            {
                PassString d = new PassString(SetSendData);
                this.Invoke(d, new object[] { strMsg });
            }
            else
            {
                tBoxClientSend.Text = strMsg;
            }
        }
        public void SetRecvData(string strMsg)
        {
            if (tBoxClientReceive.InvokeRequired == true)
            {
                PassString d = new PassString(SetRecvData);
                this.Invoke(d, new object[] { strMsg });
            }
            else
            {
                tBoxClientReceive.Text = strMsg;
            }
        }
        private void ClientHandle()
        {
            string strRecv = string.Empty;
            //IPEndPoint其实就是一个IP地址和端口的绑定,可以代表一个服务,用来Socket通讯。
            //IPAddress类中有一个 Parse()方法,可以把点分的十进制IP表示转化成IPAddress类
            IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), nPort);
            //创建套接字实例
            //这里创建的时候用ProtocolType.Tcp,表示建立一个面向连接(TCP)的Socket
            vsServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                //将所创建的套接字与IPEndPoint绑定
                vsServerSocket.Bind(ipep);
            }
            catch (SocketException ex)
            {
                MessageBox.Show("Connect Error: " + ex.Message);
                return;
            }
            Byte[] buffer = new Byte[1024];
            //设置套接字为收听模式
            vsServerSocket.Listen(10);
            //循环监听   
            while (true)
            {
                //接收服务器信息
                int bufLen = 0;               
                try
                {
                    Socket vsClientSocket = vsServerSocket.Accept();
                    bufLen=vsClientSocket.Receive(buffer);
                    vsClientSocket.Send(Encoding.ASCII.GetBytes("aaaaa"), 5, SocketFlags.None);
                  
                }
                catch (Exception ex)
                {
                    MessageBox.Show("Receive Error:" + ex.Message);                   
                }
                strRecv = Encoding.ASCII.GetString(buffer, 0, bufLen);
                SetRecvData(strRecv);                
                //vsClientSocket.Shutdown(SocketShutdown.Both);
                //vsClientSocket.Close();
            }
        }

        //发送数据
        private void btnSend_Click(object sender, EventArgs e)
        {
            byte[] data = new byte[1024];
            string ss = tBoxClientSend.Text;
            Socket centerClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint GsServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9002);
            centerClient.Connect(GsServer);
            centerClient.Send(Encoding.ASCII.GetBytes(ss));
            centerClient.Close();
        }

        private void Client_Load(object sender, EventArgs e)
        {
            //连接服务器
            //通过ThreadStart委托告诉子线程讲执行什么方法
            vsClientThread = new Thread(new ThreadStart(ClientHandle));
            vsClientThread.Start();
        }
        //窗体关闭时杀死客户端进程
        private void Client_FormClosing(object sender, FormClosingEventArgs e)
        {
            KillProcess();
        }
        //杀死客户端进程
        private void KillProcess()
        {
            Process[] processes = Process.GetProcessesByName("SocketClient");
            foreach (Process process in processes)
            {
                process.Kill();
                break;
            }
        }
    }
}
登录后复制

服务端代码:



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.Threading;
using System.Net.Sockets;
using System.Net;
using System.Diagnostics;
namespace SocketServer
{
    public partial class Server : Form
    {
        Thread vsServerThread;
        Socket vsServerSocket;      
        string strIP = "127.0.0.1";
        public delegate void PassString(string strMsg);     
        int nPort = 9002;
        public Server()
        {
            InitializeComponent();
        }
        private void SeverSendData(string strMsg)
        {
            //Control.InvokeRequired 属性,命名空间:  System.Windows.Forms
            //获取一个值,该值指示调用方在对控件进行方法调用时是否必须调用 Invoke 方法,因为调用方位于创建控件所在的线程以外的线程中。
            if (tBoxServerSend.InvokeRequired == true)
            {
                //Control.Invoke 方法 (Delegate)
                //在拥有此控件的基础窗口句柄的线程上执行指定的委托。
                PassString d = new PassString(SeverSendData);
                this.Invoke(d, new object[] { strMsg });
            }
            else
            {
                tBoxServerSend.Text = strMsg;
            }
        }
        private void SeverRecvData(string strMsg)
        {
            if (tBoxServerReceive.InvokeRequired == true)
            {
                PassString d = new PassString(SeverRecvData);
                this.Invoke(d, new object[] { strMsg });
            }
            else
            {
                tBoxServerReceive.Text = strMsg;
            }
        }       
        private void ServerStart()
        {
            string strRecv = string.Empty;
            //创建IPEndPoint实例
            IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), nPort);
            //创建一个套接字
            vsServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //将所创建的套接字与IPEndPoint绑定
            try
            {
                vsServerSocket.Bind(ipep);
            }
            catch (Exception ee)
            {
                MessageBox.Show(ee.ToString());
                return;
            }
            //设置套接字为收听模式
            vsServerSocket.Listen(10);
            int bufLen = 0;
            //循环监听  
            while (true)
            {
                //在套接字上接收接入的连接
                Socket vsClientSocket = vsServerSocket.Accept();     
                try
                {                                  
                    Byte[] buffer = new Byte[1024];
                    //在套接字上接收客户端发送的信息
                    bufLen = vsClientSocket.Receive(buffer);
                    vsClientSocket.Send(Encoding.ASCII.GetBytes("aaaaa"), 5, SocketFlags.None);
                    if (bufLen == 0)
                        continue;   
                    //将指定字节数组中的一个字节序列解码为一个字符串。
                    strRecv = Encoding.ASCII.GetString(buffer, 0, bufLen);
                    SeverRecvData(strRecv.ToString());
                }
                catch (Exception ex)
                {
                    MessageBox.Show("Listening Error: " + ex.Message);
                    vsClientSocket.Close();
                    vsServerSocket.Close();
                }
            }
        }
        private void btnSend_Click(object sender, EventArgs e)
        {
            byte[] data = new byte[1024];
            string ss = tBoxServerSend.Text;
            Socket centerClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint GsServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9001);
            centerClient.Connect(GsServer);
            centerClient.Send(Encoding.ASCII.GetBytes(ss));
            centerClient.Send(Encoding.ASCII.GetBytes(ss));
            //Thread.Sleep(100);
            //centerClient.Close();
        }
        private void Server_Load(object sender, EventArgs e)
        {
            vsServerThread = new Thread(new ThreadStart(ServerStart));
            vsServerThread.Start();
        }
        //窗体关闭时杀死客户端进程
        private void Server_FormClosing(object sender, FormClosingEventArgs e)
        {
            KillProcess();
        }
        //杀死客户端进程
        private void KillProcess()
        {
            Process[] processes = Process.GetProcessesByName("Server");
            foreach (Process process in processes)
            {
                process.Kill();
                break;
            }
        }
    }
}
登录后复制


效果如下:

客户端可以发送消息给服务端,服务端也可以发送消息给客户端。

缺点:

现在服务端只能连接一个客户端

 以上就是C#  Socket  线程的内容,更多相关内容请关注PHP中文网(www.php.cn)!


本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
2 周前 By 尊渡假赌尊渡假赌尊渡假赌
仓库:如何复兴队友
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险:如何获得巨型种子
3 周前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

使用 C# 的活动目录 使用 C# 的活动目录 Sep 03, 2024 pm 03:33 PM

使用 C# 的活动目录

C# 中的访问修饰符 C# 中的访问修饰符 Sep 03, 2024 pm 03:24 PM

C# 中的访问修饰符

C# 中的随机数生成器 C# 中的随机数生成器 Sep 03, 2024 pm 03:34 PM

C# 中的随机数生成器

C# 数据网格视图 C# 数据网格视图 Sep 03, 2024 pm 03:32 PM

C# 数据网格视图

C# 字符串读取器 C# 字符串读取器 Sep 03, 2024 pm 03:23 PM

C# 字符串读取器

C# 中的模式 C# 中的模式 Sep 03, 2024 pm 03:33 PM

C# 中的模式

C# 字符串编写器 C# 字符串编写器 Sep 03, 2024 pm 03:23 PM

C# 字符串编写器

C# 中的二进制编写器 C# 中的二进制编写器 Sep 03, 2024 pm 03:22 PM

C# 中的二进制编写器

See all articles