如何在C＃中连接到.NET Core中的Unix域套接字

我在Linux上的.NET Core中创建了一个unix套接字（Ubuntu 16.04）：

var unixSocket = "/var/run/mysqld/mysqld.sock"; var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.IP); 

现在我如何连接套接字？

.NET Core API列出了各种Socket.Connect选项，但除了第一个处理IP地址之外的所有选项：

 public void Connect(EndPoint remoteEP) public void Connect(IPAddress address, int port) public void Connect(IPAddress[] addresses, int port) public void Connect(string host, int port) 

System.Net API定义了一个DNSEndpoint和一个IPEndpoint ，但我似乎无法找到一个UnixEndpoint或类似的类传递给Socket.Connect(EndPoint remoteEP)

Answer 1

似乎没有.NET Core的内置UnixEndPoint类或者在撰写本文时实现一个的库。 Mono.Posix项目中的UnixEndPoint类可以很容易地适应.NET Core，但是：

 // copied from https://github.com/mono/mono/blob/master/mcs/class/Mono.Posix/Mono.Unix/UnixEndPoint.cs // // Mono.Unix.UnixEndPoint: EndPoint derived class for AF_UNIX family sockets. // // Authors: // Gonzalo Paniagua Javier ([e-mail]) // // (C) 2003 Ximian, Inc (http://www.ximian.com) // // // Permission is hereby granted, free of charge, to any person obtaining // a copy of this software and associated documentation files (the // "Software"), to deal in the Software without restriction, including // without limitation the rights to use, copy, modify, merge, publish, // distribute, sublicense, and/or sell copies of the Software, and to // permit persons to whom the Software is furnished to do so, subject to // the following conditions: // // The above copyright notice and this permission notice shall be // included in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // using System.Net.Sockets; using System.Text; namespace System.Net { public class UnixEndPoint : EndPoint { string filename; public UnixEndPoint (string filename) { if (filename == null) throw new ArgumentNullException ("filename"); if (filename == "") throw new ArgumentException ("Cannot be empty.", "filename"); this.filename = filename; } public string Filename { get { return(filename); } set { filename=value; } } public override AddressFamily AddressFamily { get { return AddressFamily.Unix; } } public override EndPoint Create (SocketAddress socketAddress) { /* * Should also check this * int addr = (int) AddressFamily.Unix; if (socketAddress [0] != (addr & 0xFF)) throw new ArgumentException ("socketAddress is not a unix socket address."); if (socketAddress [1] != ((addr & 0xFF00) >> 8)) throw new ArgumentException ("socketAddress is not a unix socket address."); */ if (socketAddress.Size == 2) { // Empty filename. // Probably from RemoteEndPoint which on linux does not return the file name. UnixEndPoint uep = new UnixEndPoint ("a"); uep.filename = ""; return uep; } int size = socketAddress.Size - 2; byte [] bytes = new byte [size]; for (int i = 0; i < bytes.Length; i++) { bytes [i] = socketAddress [i + 2]; // There may be junk after the null terminator, so ignore it all. if (bytes [i] == 0) { size = i; break; } } string name = Encoding.UTF8.GetString (bytes, 0, size); return new UnixEndPoint (name); } public override SocketAddress Serialize () { byte [] bytes = Encoding.UTF8.GetBytes (filename); SocketAddress sa = new SocketAddress (AddressFamily, 2 + bytes.Length + 1); // sa [0] -> family low byte, sa [1] -> family high byte for (int i = 0; i < bytes.Length; i++) sa [2 + i] = bytes [i]; //NULL suffix for non-abstract path sa[2 + bytes.Length] = 0; return sa; } public override string ToString() { return(filename); } public override int GetHashCode () { return filename.GetHashCode (); } public override bool Equals (object o) { UnixEndPoint other = o as UnixEndPoint; if (other == null) return false; return (other.filename == filename); } } } 

在项目中使用此类，可以像这样连接套接字：

 var unixSocket = "/var/run/mysqld/mysqld.sock"; var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.IP); var unixEp = new UnixEndPoint(unixSocket); socket.Connect(unixEp);