" />

欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

C#實現(xiàn)套接字發(fā)送接收數(shù)據(jù)

 更新時間:2021年11月25日 15:19:40   作者:普通還不自信的程序員  
這篇文章主要為大家詳細介紹了C#實現(xiàn)套接字發(fā)送接收數(shù)據(jù),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下

本文實例為大家分享了C#實現(xiàn)套接字發(fā)送接收數(shù)據(jù)的具體代碼,供大家參考,具體內容如下

服務端

namespace TestServer
{
    public partial class ServerForm : Form
    {
        Socket socketSend;
        // 將遠程連接的客戶端的IP地址和socket存入集合
        Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();
        public ServerForm()
        {
            InitializeComponent();
        }

        private void btnStart_Click(object sender, EventArgs e)
        {
            try
            {
                // 當點擊開始監(jiān)聽后,在服務器創(chuàng)建一個負責監(jiān)聽IP地址和端口號的socket
                Socket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                IPAddress ip = IPAddress.Any;//;IPAddress.Parse(txtServer.Text)
                IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));
                // 監(jiān)聽
                socketWatch.Bind(point);
                ShowMsg("監(jiān)聽成功");
                socketWatch.Listen(10);
                Thread th = new Thread(Listen);
                th.IsBackground = true;
                th.Start(socketWatch);
            }
            catch { }
        }

        void Listen(object o)
        {
            // 等待客戶端連接 并創(chuàng)建一個負責通信的Socket
            Socket socketWatch = o as Socket;
            while (true)
            {
                socketSend = socketWatch.Accept();
                dicSocket.Add(socketSend.RemoteEndPoint.ToString(),socketSend);
                cboUsers.Items.Add(socketSend.RemoteEndPoint.ToString());
                ShowMsg(socketSend.RemoteEndPoint.ToString() + " : " + "連接成功");
                Thread th = new Thread(Recive);
                th.IsBackground = true;
                th.Start(socketSend);
            }
        }
        
        void Recive(object o)
        {
            socketSend = o as Socket;
            while (true)
            {
                // 客戶端連接成功后,服務器應接受客戶端發(fā)來的消息
                byte[] buffer = new byte[1024 * 1024 * 2];
                // 實際接收到的有效字節(jié)數(shù)
                int r = socketSend.Receive(buffer);
                if (r == 0)
                {
                    break;
                }
                string str = Encoding.UTF8.GetString(buffer, 0, r);
                ShowMsg(socketSend.RemoteEndPoint + " : " + str);
            }
        }

        

        void ShowMsg(string str)
        {
            txtLog.AppendText(str + "\r\n");
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            Control.CheckForIllegalCrossThreadCalls = false;
        }

        private void btnSend_Click(object sender, EventArgs e)
        {
            string str = txtMsg.Text;
            byte[] buffer = Encoding.UTF8.GetBytes(str);
            string ip = cboUsers.SelectedItem.ToString();
            dicSocket[ip].Send(buffer);
            //socketSend.Send(buffer);
            txtMsg.Text = "";
        }

        private void btnSendUser_Click(object sender, EventArgs e)
        {
            string json = JsonConvert.SerializeObject(UserList());
            byte[] buffer = Encoding.UTF8.GetBytes(json);
            socketSend.Send(buffer);
        }

        private List<User> UserList()
        {
            List<User> userList = new List<User>();
            User user = null;
            string sql = "select * from user_table";
            SqlCommand cmd = SqlUtils.ConnectSql(sql);
            SqlDataReader sdr = cmd.ExecuteReader();
            while (sdr.Read())
            {
                user = new User(sdr.GetInt32(0), sdr.GetString(1), sdr.GetString(2), sdr.GetInt32(3));
                userList.Add(user);
            }
            return userList;
        }

    }
}

客戶端

namespace TestClient
{
    public partial class ClientForm : Form
    {
        Socket socketSend;
        public ClientForm()
        {
            InitializeComponent();
        }

        private void btnStart_Click(object sender, EventArgs e)
        {
            try
            {
                // 創(chuàng)建負責通信的socket
                socketSend = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
                IPAddress ip = IPAddress.Parse(txtServer.Text);
                IPEndPoint point = new IPEndPoint(ip,Convert.ToInt32(txtPort.Text));
                socketSend.Connect(point);
                ShowMsg("連接成功");
                Thread th = new Thread(Recive);
                th.IsBackground = true;
                th.Start();
            }
            catch { }
        }

        void Recive()
        {
            while (true)
            {
                // 客戶端連接成功后,服務器應接受客戶端發(fā)來的消息
                byte[] buffer = new byte[1024 * 1024 * 2];
                // 實際接收到的有效字節(jié)數(shù)
                int r = socketSend.Receive(buffer);
                if (r == 0)
                {
                    break;
                }
                string str = Encoding.UTF8.GetString(buffer, 0, r);
                ShowMsg(socketSend.RemoteEndPoint + " : " + str);
            }
        }

        void ShowMsg(string str)
        {
            txtLog.AppendText(str + "\r\n");
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            Control.CheckForIllegalCrossThreadCalls = false;
        }

        private void btnSend_Click(object sender, EventArgs e)
        {
            string str = txtMsg.Text.Trim();
            byte[] buffer = Encoding.UTF8.GetBytes(str);
            socketSend.Send(buffer);
            txtMsg.Text = "";
        }
    }
}

效果

發(fā)送json數(shù)據(jù)

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

相關文章

  • 用?FieldMask?提高?C#?gRpc?的服務性能

    用?FieldMask?提高?C#?gRpc?的服務性能

    這篇文章主要介紹了用?FieldMask?提高?C#?gRpc?的服務性能,FieldMask?是一個?protobuf?消息,包含一個名為?paths?的字段,用于指定用于指定讀取操作返回或更新操作修改的字,下文詳細內容,需要的朋友可以參考一下
    2022-03-03
  • C#多線程系列之資源池限制

    C#多線程系列之資源池限制

    這篇文章介紹了C#多線程的資源池限制,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-02-02
  • C# winform程序讀取文本中的值實例講解

    C# winform程序讀取文本中的值實例講解

    在本篇文章中小編給大家分享了關于C# winform程序讀取文本中的值的相關知識點,有興趣的朋友們學習下。
    2019-06-06
  • 詳解Unity入門之GameObject

    詳解Unity入門之GameObject

    Unity是一個Component-Based的引擎,所有物體都是GameObject。本文將詳細介紹GameObject和MonoBehaviour,感興趣的同學,可以參考下。
    2021-05-05
  • 輕松學習C#的讀寫操作

    輕松學習C#的讀寫操作

    輕松學習C#的讀寫操作,小編也是第一次接觸C#的讀寫操作,感興趣的小伙伴們可以參考一下,大家一起學習
    2015-11-11
  • C#實現(xiàn)工廠方法模式

    C#實現(xiàn)工廠方法模式

    這篇文章介紹了C#實現(xiàn)工廠模式的方法,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-07-07
  • C#實現(xiàn)對二維數(shù)組排序的方法

    C#實現(xiàn)對二維數(shù)組排序的方法

    這篇文章主要介紹了C#實現(xiàn)對二維數(shù)組排序的方法,實例分析了C#數(shù)組遍歷與排序的相關技巧,需要的朋友可以參考下
    2015-06-06
  • 深入理解C#之接口

    深入理解C#之接口

    這篇文章主要介紹了C#接口(Interface)用法,較為詳細的分析了C#中接口的功能、實現(xiàn)及使用技巧,具有一定參考借鑒價值,需要的朋友可以參考下
    2021-07-07
  • C#實現(xiàn)Base64處理的加密解密,編碼解碼示例

    C#實現(xiàn)Base64處理的加密解密,編碼解碼示例

    這篇文章主要介紹了C#實現(xiàn)Base64處理的加密解密,編碼解碼,結合實例形式分析了基于C#實現(xiàn)的base64編碼解碼操作相關技巧,需要的朋友可以參考下
    2017-01-01
  • C#實現(xiàn)json的序列化和反序列化實例代碼

    C#實現(xiàn)json的序列化和反序列化實例代碼

    這篇文章主要介紹了C#實現(xiàn)json的序列化和反序列化實例代碼,有需要的朋友可以參考一下
    2013-12-12

最新評論