#c# #.net-core
#c# #.net-ядро
Вопрос:
Я создал сокет unix в .NET Core в Linux (Ubuntu 16.04):
var unixSocket = "/var/run/mysqld/mysqld.sock";
var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.IP);
Теперь, как мне подключить сокет?
В API .NET Core перечислены различные сокеты.Параметры подключения, но все, кроме первого, имеют дело с 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)
Система.Net API определяет a DNSEndpoint и an IPEndpoint , но, похоже, я не могу найти UnixEndpoint или аналогичный класс для передачи Socket.Connect(EndPoint remoteEP)
Комментарии:
1. Я использую @PeterDuniho . NET core в Linux (обновил мой вопрос, чтобы отразить это). Наверняка есть способ вызвать POSIX для открытия доменного сокета unix? Пожалуйста, снимите пометку с этого как дубликат, отмеченный дубликат не относится к этому вопросу.
2. Теперь это доступно в .NET Standard 2.1 через UnixDomainSocketEndPoint .
3. @MarkG Добавьте это в качестве ответа, пожалуйста, чтобы его можно было выбрать / поддержать.
Ответ №1:
Обновление: .NET Standard 2.1 / .NET Core 2.1 содержит класс UnixDomainSocketEndPoint
Оригинальный ответ, применяется к версиям .NET Standard / .NET Core до версии 2.1:
Похоже, что на момент написания этой статьи не существует встроенного UnixEndPoint класса для .NET Core или библиотеки, которая его реализует. Класс UnixEndPoint из проекта Mono.Posix может быть легко адаптирован для работы с .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 (gonzalo@ximian.com)
//
// (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 amp; 0xFF))
throw new ArgumentException ("socketAddress is not a unix socket address.");
if (socketAddress [1] != ((addr amp; 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);
Комментарии:
1. Конечная точка UNIXDOMAINSOCKET уже существует начиная с .net core 2.1: learn.microsoft.com/en-us/dotnet/api /…
Ответ №2:
using System.Net.Sockets;
var unixSocketName = "/var/run/mysqld/mysqld.sock";
var unixSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.IP);
unixSocket.Connect(new UnixDomainSocketEndPoint(unixSocketName));
Ответ №3:
Поскольку я не смог найти хороший пример для сокетов unix, я разработал свой собственный. Это очень элементарно и не требует большого количества исправлений, но это работает.
Вот оно:
using System;
using System.Net.Sockets;
using System.Threading;
namespace mps.unix.socket
{
public class UnixSocket
{
private Socket recvSocket;
private string unixSocketpath; // needed for cleanup
private bool running = true;
private byte[] data = new byte[0];
public UnixSocket(string unixSocket)
{
this.unixSocketpath = unixSocket;
this.recvSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
System.IO.File.Delete(unixSocketpath);
var ep = new UnixDomainSocketEndPoint(unixSocketpath);
recvSocket.Bind(ep);
recvSocket.Listen();
Thread w = new Thread(worker);
w.Start();
}
private void worker()
{
while (this.running)
{
try
{
var clientSocket = this.recvSocket.Accept(); // waits for 'client' to 'connect'
Thread t = new Thread(delegate () { clientWorker(clientSocket); });
t.Start();
}
catch (Exception) { }
}
}
private void clientWorker(Socket s)
{
while (running)
{
byte[] d = new byte[s.ReceiveBufferSize];
int length = s.Receive(d);
lock (this.data)
{
byte[] newData = new byte[this.data.Length length];
Buffer.BlockCopy(this.data, 0, newData, 0, this.data.Length);
Buffer.BlockCopy(d, 0, newData, this.data.Length, length);
this.data = newData;
}
}
s.Close();
}
public bool isRunning()
{
return this.running;
}
public void Stop()
{
this.running = false;
Thread.Sleep(10);
this.recvSocket.Close();
System.IO.File.Delete(this.unixSocketpath);
}
public bool hasData()
{
return this.data.Length > 0;
}
public int dataLength()
{
lock (this.data)
return this.data.Length;
}
public byte[] getData()
{
lock (this.data)
{
var d = this.data;
this.data = new byte[0];
return d;
}
}
public byte[] getData(int length)
{
lock (this.data)
{
if (this.data.Length < length)
return this.getData();
//var d = this.data.Take(length).ToArray();
//var rest = new byte[0];
byte[] taken = new byte[length];
byte[] rest = new byte[this.data.Length - length];
Buffer.BlockCopy(this.data, 0, taken, 0, length);
Buffer.BlockCopy(this.data, length, rest, 0, rest.Length);
this.data = rest;
return taken;
}
}
}
}
Вот небольшая программа, в которой вы можете увидеть, как использовать класс:
using System;
using System.Threading;
using mps.unix.socket;
namespace TEST_mps.unix.socket
{
class Program { static void Main(string[] args) { var P = new TEST(); } }
class TEST
{
public TEST()
{
var v = new UnixSocket("/tmp/test.mps.unix.sock");
Thread t = new Thread(delegate () { runner(v); });
t.Start();
}
private void runner(UnixSocket s)
{
while (s.isRunning())
{
Thread.Sleep(5);
if (s.hasData())
{
string responseData = System.Text.Encoding.ASCII.GetString(s.getData());
Console.WriteLine("Message received: {0}", responseData);
if (responseData == "END")
s.Stop();
}
}
}
}
}
Я скомпилировал это с помощью .Net 6.0 для linux-x64.
Для тестирования запустите программное обеспечение, а затем отправьте что-нибудь в сокет:
На сервере:
root@server:# ./test.mps.unix.socket
Message received: this is a message for the socket!
Message received: here is another one..
Message received: END
root@server:#
Из другой оболочки:
root@server:# echo -n 'this is a message for the socket!' | socat UNIX-CONNECT:/tmp/test.mps.unix.sock STDIO
root@server:# echo -n 'here is another one..' | socat UNIX-CONNECT:/tmp/test.mps.unix.sock STDIO
root@server:# echo -n 'END' | socat UNIX-CONNECT:/tmp/test.mps.unix.sock STDIO
Если вы обнаружили ошибки или можете внести улучшения, скажите мне, и я посмотрю, сможем ли мы добавить это в пример 