UNIX Socket：不同進程之間能夠直接交換數據進行進程間通信（IPC）
UNIX socket概念
UNIX Socket（也稱為本地套接字或IPC套接字）是一種在同一臺計算機上進行進程間通信（IPC）的機制。它提供了一種可靠而高效的方式，使不同進程之間能夠直接交換數據。UNIX Socket基于文件系統的抽象概念，使用一個特殊的文件來表示套接字。與網絡套接字不同，UNIX Socket僅限于同一主機上的進程間通信，不涉及網絡協議棧的使用。
UNIX socket特點
同步和異步通信
UNIX Socket允許進程進行同步或異步通信。對于同步通信，發送進程會阻塞直到接收進程接收到數據；對于異步通信，發送進程可以繼續執行其他任務而不需要等待接收進程響應。
全雙工通信
UNIX Socket允許進程在同一個套接字上進行雙向通信，既可以發送數據也可以接收數據。
面向字節流
UNIX Socket以字節流的形式傳輸數據，不關心數據的消息邊界。這意味著發送的數據可以分割成多個部分，也可以將多個消息組合成一個單獨的數據塊。
高性能
由于UNIX Socket只涉及本地通信，沒有網絡協議的開銷，因此它通常比網絡套接字更高效。
UNIX socket優勢
由于UNIX Socket 使用套接字的概念，類似于網絡套接字，但其使用的是文件系統路徑而不是IP地址和端口號。 UNIX Socket 具有以下優點：
- 可靠性：UNIX Socket 提供可靠的進程間通信機制，數據傳輸過程中會進行錯誤檢測和重傳，確保數據的完整性和可靠性。
- 高效性：UNIX Socket 是基于內核的通信機制，數據傳輸過程中減少了不必要的數據拷貝，使得數據傳輸更加高效。
- 低延遲：由于 UNIX Socket 在內核層面實現，數據傳輸不需要經過網絡協議棧，因此具有較低的延遲。
- 安全性：UNIX Socket 基于文件系統路徑進行通信，只有相應權限的進程才能進行通信，增強了通信的安全性。
- 靈活性：UNIX Socket 可以在同一臺計算機上的不同進程之間進行通信，使得進程間的交互更加靈活。
- 支持多種編程語言：UNIX Socket 可以在多種編程語言中使用，如C/C++、Python等，使得不同語言的進程之間可以進行通信。
- 跨平臺兼容性：盡管名字中包含 UNIX，但 UNIX Socket 在許多操作系統上都有支持，包括 Linux、macOS 等。
UNIX Socket適用場景
UNIX Socket可以在不同編程語言中使用，并且廣泛應用于各種場景，例如：
- 進程間通信（IPC）：不同進程之間通過UNIX Socket進行數據交換，例如父子進程、無關進程或者共享內存的進程之間。
- 本地服務器和客戶端：UNIX Socket可用于構建本地服務器，接受來自客戶端的連接請求并提供服務。
- 網絡編程的模擬和測試：在本地開發環境中，使用UNIX Socket可以模擬網絡連接，方便進行調試和測試。
- 守護進程和系統服務：UNIX Socket作為進程間通信的一種方式，可用于實現守護進程和系統服務之間的通信。
UNIX Socket 步驟
創建 Socket：
- 使用 `socket()` 函數創建一個套接字，指定協議組、類型和協議。
- 常見的協議族有 `AF_UNIX`（用于 UNIX 域套接字）和 `AF_INET`（用于網絡套接字）。
- 常見的類型有 `SOCK_STREAM`（用于可靠的面向連接的通信）和 `SOCK_DGRAM`（用于無連接的通信）。
綁定 Socket 到地址：
- 對于 UNIX 域套接字，使用 `bind()` 函數將套接字綁定到一個文件路徑。
- 對于網絡套接字，使用 `bind()` 函數將套接字綁定到一個 IP 地址和端口號。
監聽連接請求（對于面向連接型套接字）：
- 對于 UNIX 域套接字，使用 `listen()` 函數開始監聽連接請求。
- 對于網絡套接字，使用 `listen()` 函數并指定最大等待連接數量。
接受連接請求（對于面向連接型套接字）：
- 使用 `accept()` 函數接受客戶端的連接請求，并創建一個新的套接字用于與客戶端進行通信。
進行數據傳輸：
- 對于面向連接型套接字，使用 `send()` 和 `recv()` 函數在客戶端和服務器之間進行數據傳輸。
- 對于無連接型套接字，可以使用 `sendto()` 和 `recvfrom()` 函數進行數據傳輸。
關閉 Socket：
- 使用 `close()` 函數關閉套接字，釋放相關資源。
WPF 接入 UNIX Socket 開發案例
在WPF應用程序中創建UNIX Socket的服務端和客戶端，可以使用System.Net.Sockets.Socket類。
服務端（Server）：
using System;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
namespace UnixSocketExample
{
public partial class MainWindow : Window
{
private const string SocketFilePath = "/path/to/unix/socket"; // UNIX Socket文件路徑
public MainWindow()
{
InitializeComponent();
}
private async void StartButton_Click(object sender, RoutedEventArgs e)
{
try
{
var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
// 如果Socket文件已存在，則先刪除
if (System.IO.File.Exists(SocketFilePath))
{
System.IO.File.Delete(SocketFilePath);
}
// 綁定并開始監聽UNIX Socket
socket.Bind(new UnixDomainSocketEndPoint(SocketFilePath));
socket.Listen(1);
await Task.Run(() =>
{
while (true)
{
var clientSocket = socket.Accept(); // 接受客戶端連接
byte[] buffer = Encoding.ASCII.GetBytes("Hello from server"); // 要發送的數據
clientSocket.Send(buffer); // 向客戶端發送數據
clientSocket.Close(); // 關閉客戶端連接
}
});
}
catch (Exception ex)
{
MessageBox.Show($"Error: {ex.Message}", "Server Error", MessageBoxButton.OK, MessageBoxImage.Error);
}
}
}
}客戶端（Client）：
using System;
using System.Net.Sockets;
using System.Text;
using System.Windows;
namespace UnixSocketExample
{
public partial class MainWindow : Window
{
private const string SocketFilePath = "/path/to/unix/socket"; // UNIX Socket文件路徑
public MainWindow()
{
InitializeComponent();
}
private void ConnectButton_Click(object sender, RoutedEventArgs e)
{
try
{
var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
socket.Connect(new UnixDomainSocketEndPoint(SocketFilePath)); // 連接到服務端
byte[] buffer = new byte[1024];
int bytesRead = socket.Receive(buffer); // 接收數據
string receivedData = Encoding.ASCII.GetString(buffer, 0, bytesRead);
ReceiveTextBox.Text = receivedData; // 顯示接收到的數據
socket.Close(); // 關閉客戶端連接
}
catch (Exception ex)
{
MessageBox.Show($"Error: {ex.Message}", "Connection Error", MessageBoxButton.OK, MessageBoxImage.Error);
}
}
}
}在這個例子中，主窗口分別包含一個“Start”按鈕（服務端）和一個“Connect”按鈕（客戶端），以及一個用于展示接收到的數據的文本框。服務端代碼負責創建UNIX Socket并綁定到指定的文件路徑，然后開始監聽連接請求。當客戶端連接時，服務端向客戶端發送一條消息，并關閉連接。客戶端代碼負責連接到服務端的UNIX Socket，接收服務端發送的數據，并將接收到的數據顯示在文本框中。
UNIX Socket進程間通信之序列化
使用UNIX Socket進行進程間通信時，序列化是一個重要的問題。由于UNIX Socket只能傳輸字節流，而對象是無法直接傳輸的，因此需要將對象進行序列化成字節流再傳輸，接收方接收到字節流后再進行反序列化還原為對象。常用的解決方案有：
- 選擇合適的序列化方式：在.NET框架中有多種序列化方式可供選擇，例如XML序列化、JSON序列化和二進制序列化等。您可以根據實際需求選擇適合的序列化方式。注意，需要確保序列化方式在進程間通信中是兼容的。
- 定義數據傳輸的數據結構：使用類或結構體來定義數據傳輸的格式和結構。這些類或結構體需要進行序列化和反序列化。
- 序列化和反序列化：在發送方，將要傳輸的對象進行序列化成字節流，并通過UNIX Socket發送；在接收方，接收到字節流后進行反序列化還原為對象。
案例演示如何使用BinaryFormatter進行對象的二進制序列化和反序列化：
using System;
using System.IO;
using System.Net.Sockets;
using System.Runtime.Serialization.Formatters.Binary;
// 發送方
var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
socket.Connect(new UnixDomainSocketEndPoint("/path/to/unix/socket"));
var data = new MyData { Name = "Alice", Age = 30 }; // 要傳輸的對象
var formatter = new BinaryFormatter();
using (var stream = new MemoryStream())
{
formatter.Serialize(stream, data); // 對象序列化到內存流中
var buffer = stream.ToArray(); // 獲取字節流數據
socket.Send(buffer); // 發送字節流
}
socket.Close();
// 接收方
var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
listener.Bind(new UnixDomainSocketEndPoint("/path/to/unix/socket"));
listener.Listen(1);
var clientSocket = listener.Accept();
var receivedBuffer = new byte[1024];
var bytesRead = clientSocket.Receive(receivedBuffer); // 接收字節流
using (var stream = new MemoryStream(receivedBuffer, 0, bytesRead))
{
var receivedData = formatter.Deserialize(stream) as MyData; // 字節流反序列化為對象
Console.WriteLine($"Received: {receivedData.Name}, {receivedData.Age}");
}
clientSocket.Close();
listener.Close();
// 要傳輸的數據結構
[Serializable]
public class MyData
{
public string Name { get; set; }
public int Age { get; set; }
}在這個示例中，發送方將MyData對象進行二進制序列化，并通過UNIX Socket發送字節流。接收方接收到字節流后，使用相同的二進制序列化方式進行反序列化還原為MyData對象。要注意的是，由于不同平臺和不同開發環境的序列化機制可能存在差異，因此在進行跨平臺的進程間通信時，需要確保序列化方式的兼容性。另外，如果要序列化的對象是自定義類或結構體，需要將其標記為可序列化（使用[Serializable]特性）才能進行序列化和反序列化操作。
