c#socket TCP同步網路通信

来源:https://www.cnblogs.com/forever-Ys/archive/2018/12/07/10085799.html
-Advertisement-
Play Games

一、socket簡介 socket就是套接字,它是引用網路連接的特殊文件描述符,由三個基本要素組成: 1: AddressFamily(網路類型) 2: SocketType(數據傳輸類型) 3:ProtocolType(採用的網路協議) 下麵是可用於IP通信的套接字組合及其常用的屬性和方法 二、s ...


一、socket簡介

  socket就是套接字,它是引用網路連接的特殊文件描述符,由三個基本要素組成:

    1: AddressFamily(網路類型)

    2: SocketType(數據傳輸類型)

    3:ProtocolType(採用的網路協議)

  下麵是可用於IP通信的套接字組合及其常用的屬性和方法

 

二、socket與網路通信 

  IP連接領域有兩種通信類型:面向連接的和無連接的,這裡我要講的是面向連接的,使用TCP協議來建立兩個IP的值端點之間的會話,下麵是它的基本步驟。

    a:建立一個套接字

    b:綁定本機的IP和埠

    c:使用listen()方法監聽別人發過來的東西

    d:如果監聽到連接,則可以使用Send/Receive來執行操作

    e:完成後使用Close()方法進行關閉

  工作原理如圖所示:

  

 

三、一個簡單的同步通信示例

  1.伺服器端

using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace socket服務端
{
    class Program
    {
        static void Main(string[] args)
        {
            int port = 23456;//埠號
            int recv;//記錄客戶端信息的長度
            string address = "127.0.0.1";//IP地址,指向localhost主機名,常用於程式調試
            IPAddress addr = IPAddress.Parse(address);
            IPEndPoint ipe = new IPEndPoint(addr, port);
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            socket.Bind(ipe);//綁定埠
            socket.Listen(0);//開始監聽,0表示任意數量
            Console.WriteLine("已啟動監聽,等待客戶端連接。");
            Socket clientSocket = socket.Accept();
            IPEndPoint clientIp = (IPEndPoint)clientSocket.RemoteEndPoint;//獲取遠程終結點信息
            if (clientSocket != null)
                Console.WriteLine("成功與{0}的客戶端建立聯繫",clientIp);
            while (true)//用死迴圈不斷執行
            {
                try
                {
                    byte[] data = new byte[1024];
                    recv = clientSocket.Receive(data);//獲取客戶端傳過來的信息
                    if (recv == 0)
                        break;
                    Console.WriteLine("客戶端發來信息:{0}",Encoding.ASCII.GetString(data, 0, recv));
                    Console.Write("輸入要發送的信息:");
                    String input = Console.ReadLine();
                    clientSocket.Send(Encoding.ASCII.GetBytes(input));
                }
                catch(Exception ex)
                {
                    Console.WriteLine("ERROR:{0}", ex.Message);
                }
            }
            Console.WriteLine("斷開連接");
            clientSocket.Close();
            socket.Close();
        }
    }
}

 

  2.客戶端

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

namespace socket客戶端
{
    class Program
    {
        static void Main(string[] args)
        {
            int port = 23456;
            string address = "127.0.0.1";
            byte[] data = new byte[1024];
            IPAddress addr = IPAddress.Parse(address);
            IPEndPoint ipe = new IPEndPoint(addr, port);
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            socket.Connect(ipe);
            Console.WriteLine("與伺服器連接成功");      

            try
            {
                while (true)
                {
                    Console.Write("輸入信息內容:");
                    string input = Console.ReadLine();
                    if (input == "exit")
                        break;
                    socket.Send(Encoding.ASCII.GetBytes(input));//發送數據
                    data = new byte[1024];
                    int recv;
                    string strData;
                    recv = socket.Receive(data);
                    strData = Encoding.ASCII.GetString(data, 0, recv);
                    Console.WriteLine("伺服器發來內容:{0}",strData);
                }
            }
            catch (SocketException ex)
            {
                Console.WriteLine(ex.ToString());
            }
            Console.WriteLine("斷開連接...");
            socket.Shutdown(SocketShutdown.Both);
            socket.Close();
            Console.ReadKey();
        }
    }
}

   接下來對上面一些內容進行解釋

    a.埠號:32位無符號整形,範圍是0~65535,0~1023被系統進程和通信協議使用,1024~49251是用戶可以使用的埠

    b.IPAddress類: 該類有一個Parse()方法,可以把點分的十進位IP轉化為IPAdress類, 它還有四個可讀欄位

           Any:用於代表本地系統可用的任何IP地址

           Broadcase:用於代表本地網路的IP廣播地址

           Loopback:用於代表本地系統的回送地址

           None:用於代表本地系統上沒有網路介面

    c.IPEndPoint是一個埠和IP地址的綁定,可以代表一個服務,用來Socket通信,可以通過兩種方法構造

           IPEndPoint( long address, int pot);

          IPEndPoint( IPAddress address, int pot)'

    d. Accept 以同步方式從偵聽套接字,在連接請求隊列中提取第一個掛起的連接請求,然後創建並返回一個新Socket。 不能使用此返回Socket為接受任何其他連接的連接隊列。 但是,可以調用RemoteEndPoint方法所返回的Socket來標識遠程主機的網路地址和埠號。

    e.Receive()從綁定的 Socket套接字接收數據,將數據存入接收緩衝區。

 

註:同步通信每發完一個數據包後,需要等待接收方響應後再繼續發送下一個數據包

       運行時先啟動伺服器端,再啟動客戶端

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 對象的創建 虛擬機遇到一條new指令時,首先檢查指令的參數能否在常量池中定位到一個類的符號引用,並且檢查這個符號引用代表的類是否已經被載入、解析和初始化過。如果沒有,必須先執行相應的類載入過程。 接下來虛擬機為新生對象分配記憶體。對象所需要的記憶體在類載入完成後可以被完全確定,所以只需要把一塊確定大小的 ...
  • 題意:給出倆個整數a,b(不超過10^9) ,求a+b的值 ,並按照xxx,xxx,xxx的格式輸出 ...
  • 實現分散式鎖目前有三種流行方案,分別為基於資料庫、Redis、Zookeeper的方案,其中前兩種方案網路上有很多資料可以參考,本文不做展開。我們來看下使用Zookeeper如何實現分散式鎖。 什麼是Zookeeper? Zookeeper(業界簡稱zk)是一種提供配置管理、分散式協同以及命名的中心 ...
  • logging 日誌模塊 一,級別的概念 二,修改配置信息 #format的多種格式 三,具體需求的實現 #暫時忽略,要用到面向對象的值是,而且可以通過生成器setlevel過濾 更改需求,實現對多個對象不同需求的實現 重點,四,引用配置模塊 #logging.config 專門用於配置loggin ...
  • 一、函數介面 |介面|參數|返回類型|描述| |: :|: :|: :|: :| |Predicate<T>|T|boolean|用來比較操作| |Consumer<T>|T|void|沒有返回值的函數| |Function|T|R|有返回值的函數| |Supplier< ...
  • #__author:Mifen #date: 2018/12/6 import time ''' 時間戳是一種用於表示時間的方式。從1970年1月1日0時0分0秒0毫秒開始到指定時間的秒數。世間戳也叫做unix時間戳,1970年1月1日成為unix元年。 作用:是為了方便時間的統一運算。 1.從19... ...
  • 開始講解之前,先列出本章的提綱,如下圖所示: 5.1 String類 5.1.1 聲明字元串 5.1.2 創建字元串 輸出結果如下圖所示: 5.2 連接字元串 5.2.1 連接多個字元串 註意事項:Java中一句相連的字元串不能分開在兩行中寫,如下圖所示 可以看出,這種寫法是錯誤,無法編譯通過,如果 ...
  • 很久之前,就有同學問我CYQ.Data能不能支持下PostgreSQL,之後小做了下調查,發現這個資料庫用的人少,加上各種因素,就一直沒動手。 前兩天,不小心看了一下Github上的消息:看到這個問題又被重新提了出來了,於是,鬧吧! ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...