H.Pipes 14.0.0

There is a newer version of this package available.
See the version list below for details.
dotnet add package H.Pipes --version 14.0.0                
NuGet\Install-Package H.Pipes -Version 14.0.0                
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="H.Pipes" Version="14.0.0" />                
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add H.Pipes --version 14.0.0                
#r "nuget: H.Pipes, 14.0.0"                
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install H.Pipes as a Cake Addin
#addin nuget:?package=H.Pipes&version=14.0.0

// Install H.Pipes as a Cake Tool
#tool nuget:?package=H.Pipes&version=14.0.0                

Async Named Pipe Wrapper for .NET Standard 2.0

Language License Requirements Build Status

A simple, easy to use, strongly-typed, async wrapper around .NET named pipes.

Features

  • Create named pipe servers that can handle multiple client connections simultaneously.
  • Send strongly-typed messages between clients and servers: any serializable .NET object can be sent over a pipe and will be automatically serialized/deserialized, including cyclical references and complex object graphs.
  • Async
  • Requires .NET Standard 2.0
  • Supports large messages - up to 300 MiB.
  • Server restart automatically
  • Automatically wait for the release of the pipe for the server, if it is already in use
  • Automatically waiting for a server pipe creating when client connecting
  • Automatic reconnect with a given interval and at each client.WriteAsync, if necessary
  • Supports variable formatters, default - BinaryFormatter which uses System.Runtime.Serialization.BinaryFormatter inside
  • Also available ready formatters in separate nuget packages: H.Formatters.Newtonsoft.Json, H.Formatters.System.Text.Json and H.Formatters.Ceras
  • Supports PipeAccessRule's(see H.Pipes.AccessControl nuget package) or more complex code to access using the PipeServer.PipeStreamInitializeAction property

Nuget

NuGet NuGet NuGet NuGet NuGet

// All clients and servers that do not need support AccessControl.
Install-Package H.Pipes

// Servers that need support AccessControl.
Install-Package H.Pipes.AccessControl

// If you want to transfer any data that can be serialized/deserialized in json using Newtonsoft.Json.
Install-Package H.Formatters.Newtonsoft.Json

// If you want to transfer any data that can be serialized/deserialized in json using System.Text.Json.
Install-Package H.Formatters.System.Text.Json

// If you want to transfer any data that can be serialized/deserialized in binary using Ceras.
Install-Package H.Formatters.Ceras

Usage

Server:

await using var server = new PipeServer<MyMessage>(pipeName);
server.ClientConnected += async (o, args) =>
{
    Console.WriteLine($"Client {args.Connection.PipeName} is now connected!");

    await args.Connection.WriteAsync(new MyMessage
    {
        Text = "Welcome!"
    });
};
server.ClientDisconnected += (o, args) =>
{
    Console.WriteLine($"Client {args.Connection.PipeName} disconnected");
};
server.MessageReceived += (sender, args) =>
{
    Console.WriteLine($"Client {args.Connection.PipeName} says: {args.Message}");
};
server.ExceptionOccurred += (o, args) => OnExceptionOccurred(args.Exception);

await server.StartAsync();

await Task.Delay(Timeout.InfiniteTimeSpan);

Client:

await using var client = new PipeClient<MyMessage>(pipeName);
client.MessageReceived += (o, args) => Console.WriteLine("MessageReceived: " + args.Message);
client.Disconnected += (o, args) => Console.WriteLine("Disconnected from server");
client.Connected += (o, args) => Console.WriteLine("Connected to server");
client.ExceptionOccurred += (o, args) => OnExceptionOccurred(args.Exception);

await client.ConnectAsync();

await client.WriteAsync(new MyMessage
{
    Text = "Hello!",
});

await Task.Delay(Timeout.InfiniteTimeSpan);

Notes:

  • To use the server inside the WinForms/WPF/Other UI application, use Task.Run() or any alternative.
  • Be careful and call Dispose before closing the program/after the end of use. Pipes are system resources and you might have problems restarting the server if you don't properly clean up the resources.

Custom Formatters

Since BinaryFormatter is used by default, you should check out this article: https://docs.microsoft.com/en-us/dotnet/standard/serialization/binaryformatter-security-guide

Install-Package H.Formatters.Newtonsoft.Json
Install-Package H.Formatters.System.Text.Json
Install-Package H.Formatters.Ceras
using H.Formatters;

await using var server = new PipeServer<MyMessage>(pipeName, formatter: new NewtonsoftJsonFormatter());
await using var client = new PipeClient<MyMessage>(pipeName, formatter: new NewtonsoftJsonFormatter());

Access Control

[!WARNING] this is only available for the Windows platform.

Install-Package H.Pipes.AccessControl
using System.IO.Pipes;
using H.Pipes.AccessControl;

await using var server = new PipeServer<string>(pipeName);

// You can set PipeSecurity
var pipeSecurity = new PipeSecurity();
pipeSecurity.AddAccessRule(new PipeAccessRule(new SecurityIdentifier(WellKnownSidType.BuiltinUsersSid, null), PipeAccessRights.ReadWrite, AccessControlType.Allow));

server.SetPipeSecurity(pipeSecurity);

// or just add AccessRule's (Please be careful, the server will only consider AccessRules from the last call AddAccessRules())
server.AddAccessRules(new PipeAccessRule(new SecurityIdentifier(WellKnownSidType.BuiltinUsersSid, null), PipeAccessRights.ReadWrite, AccessControlType.Allow));

// or just
server.AllowUsersReadWrite();

Encryption

[!WARNING] this is only available for the Windows platform.

Install-Package H.Formatters.Inferno
using H.Formatters;

await using var server = new PipeServer<MyMessage>(pipeName, formatter: new SystemTextJsonFormatter());
server.EnableEncryption();

await using var client = new PipeClient<MyMessage>(pipeName, formatter: new SystemTextJsonFormatter());
client.EnableEncryption();

await client.ConnectAsync(source.Token).ConfigureAwait(false);
// Waits for key exchange.
await client.Connection!.WaitExchangeAsync();

server.ClientConnected += async (_, args) =>
{
    // Waits for key exchange.
    await args.Connection.WaitExchangeAsync();

    await args.Connection.WriteAsync(new MyMessage
    {
        Text = "Welcome!"
    }, source.Token).ConfigureAwait(false);
};

GetImpersonationUserName

server.ClientConnected += async (o, args) =>
{
    var name = args.Connection.GetImpersonationUserName();

    Console.WriteLine($"Client {name} is now connected!");
};

Inter-process communication

I recommend that you take a look at my other library if you plan on doing IPC. This is a SourceGenerator that will generate client and server code based on the presented interface.

Contacts

Product Compatible and additional computed target framework versions.
.NET net5.0 was computed.  net5.0-windows was computed.  net6.0 was computed.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 is compatible.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
.NET Core netcoreapp2.0 was computed.  netcoreapp2.1 was computed.  netcoreapp2.2 was computed.  netcoreapp3.0 was computed.  netcoreapp3.1 was computed. 
.NET Standard netstandard2.0 is compatible.  netstandard2.1 is compatible. 
.NET Framework net461 was computed.  net462 is compatible.  net463 was computed.  net47 was computed.  net471 was computed.  net472 was computed.  net48 was computed.  net481 was computed. 
MonoAndroid monoandroid was computed. 
MonoMac monomac was computed. 
MonoTouch monotouch was computed. 
Tizen tizen40 was computed.  tizen60 was computed. 
Xamarin.iOS xamarinios was computed. 
Xamarin.Mac xamarinmac was computed. 
Xamarin.TVOS xamarintvos was computed. 
Xamarin.WatchOS xamarinwatchos was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (9)

Showing the top 5 NuGet packages that depend on H.Pipes:

Package Downloads
H.Pipes.AccessControl

This package adds AccessControl extensions for PipeServerSetPipeSecurity()

H.Formatters.Inferno

This package adds InfernoFormatter(based on Inferno). It allows encrypt your messages.

H.ProxyFactory.Pipes

Features: - Create proxy objects that look exactly like the original objects - Proxy target can be located anywhere where there is access to pipes ⭐ Last 10 features: - feat: Updated NuGet packages. 2022-01-19 - feat: Added ContinuousIntegrationBuild. 2021-11-29 - feat: Added separate H.ProxyFactory.Remote library. 2021-11-29 - feat: Added separate H.Ipc.Core library. Refactored. 2021-11-29 - feat: Added RemoteProxyServer.ObjectCreated event. 2021-11-28 - feat: Implemented safe CreateObjectAsync. 2021-10-30 - feat: Added try catch to example app. 2021-10-30 - feat: Added CLSCompliant(true). 2021-10-30 - feat: to auto-releases. 2021-10-29 - feat: Implemented example WPF app. 2021-10-29 🐞 Last 10 bug fixes: - fix(test): Removed H.Recorders.NAudioRecorder package from tests. 2022-01-19 - fix: Renamed H.Ipc.Messages to H.ProxyFactory.Remote.Messages. 2021-11-30 - fix: Changed CI build to windows-latest. 2021-10-30 - fix: Added Factory.LoadAssemblyAsync to example app. 2021-10-30 - fix: Fixed H.ProxyFactory.Pipes warnings. 2021-10-30 - fix: Fixed H.ProxyFactory warnings. 2021-10-30

H.Utilities.PipeProxyFactory

Features: - Create proxy objects that look exactly like the original objects - Proxy target can be located anywhere where there is access to pipes

T.Pipes

T.Pipes Core. T.Pipes.Abstractions implementaion with T.Pipes.SourceGeneration support.

GitHub repositories (2)

Showing the top 2 popular GitHub repositories that depend on H.Pipes:

Repository Stars
mgth/LittleBigMouse
DPI Aware mouse move across screens
ad2017gd/RainbowTaskbar
Powerful, customizable Windows 10/11 taskbar effects.
Version Downloads Last updated
15.0.0 164 12/6/2024
14.0.0 6,383 10/21/2024
2.2.2-dev.2 54 10/21/2024
2.2.1 888 10/19/2024
2.2.1-dev.2 75 10/19/2024
2.1.0-dev.322 814 1/20/2024
2.1.0-dev.318 140 12/18/2023
2.0.59 72,400 12/8/2023
2.0.56 2,766 11/27/2023
2.0.53 23,818 7/24/2023
2.0.51 11,520 5/25/2023
2.0.47 15,078 2/27/2023
2.0.46 975 2/26/2023
2.0.45 7,732 2/2/2023
2.0.44 9,021 1/10/2023
2.0.43 1,931 1/5/2023
2.0.42 31,856 9/14/2022
2.0.41 1,983 9/9/2022
2.0.40 3,788 8/26/2022
2.0.39 1,412 8/26/2022
2.0.38 12,104 6/2/2022
2.0.37 3,881 4/21/2022
2.0.35 79,560 3/17/2022
2.0.34 1,569 3/12/2022
2.0.33 1,477 3/12/2022
2.0.32 1,412 3/12/2022
2.0.31 2,374 3/11/2022
2.0.30 1,464 3/11/2022
2.0.29 1,472 3/11/2022
2.0.26 1,501 3/7/2022
2.0.25 1,441 3/6/2022
2.0.23 9,510 12/21/2021
2.0.22 975 12/21/2021
2.0.21 6,906 12/20/2021
2.0.20 992 12/20/2021
2.0.19 1,054 12/20/2021
2.0.18 1,087 12/20/2021
2.0.17 1,020 12/20/2021
2.0.16 979 12/20/2021
2.0.15 914 12/20/2021
2.0.14 2,345 12/5/2021
2.0.13 914 12/5/2021
1.15.12 1,018 12/5/2021
1.15.11 1,681 11/29/2021
1.15.10 4,580 11/25/2021
1.15.9 3,082 11/25/2021
1.15.8 3,307 11/25/2021
1.15.7 3,180 11/25/2021
1.15.6 4,456 11/24/2021
1.15.4 6,402 11/24/2021
1.15.2 3,933 10/22/2021
1.15.1 990 10/22/2021
1.14.8 8,412 1/4/2021
1.14.7 4,266 12/15/2020
1.14.6 10,925 12/9/2020
1.14.5 1,102 12/9/2020
1.14.4 4,654 11/22/2020
1.14.2 1,162 11/22/2020
1.14.1 2,910 10/8/2020
1.14.0 1,185 10/8/2020
1.13.4 1,243 10/8/2020
1.13.1 1,484 7/5/2020
1.13.0 1,533 5/20/2020
1.12.3 1,518 2/2/2020
1.12.2 2,482 2/1/2020
1.12.1 1,305 2/1/2020
1.0.12 2,755 1/29/2020
1.0.11 1,516 1/28/2020
1.0.10 1,192 1/28/2020
1.0.9 1,328 1/14/2020
1.0.8 1,272 1/14/2020
1.0.7 1,508 1/12/2020
1.0.6.1 1,262 1/11/2020
1.0.6 1,340 1/10/2020
1.0.5 1,125 1/10/2020
1.0.4 1,126 1/10/2020
1.0.3 1,184 1/10/2020
1.0.2.3 1,131 1/9/2020
1.0.2.2 1,118 1/9/2020
1.0.2.1 1,098 1/9/2020
1.0.2 1,091 1/8/2020
1.0.1 1,117 1/8/2020
1.0.0 1,165 1/7/2020

⭐ Last 10 features:
- feat: Use same versions for all packages. 2024-10-21
- feat: Added MessagePackFormatter<T1> to H.Formatters.MessagePack lib. 2024-01-20
- feat: Added PipeClient.CreatePipeStreamForConnectionFunc. 2023-12-08
- feat: Updated versioning. 2023-12-08
- feat: Added support for WriteOnly PipeServer. 2023-12-08
- feat: Added PipeServer.CreatePipeStreamForConnectionFunc. 2023-12-08
- feat: Use MessagePackFormatter by default on net8.0. 2023-11-27
- feat: Update to net8.0. 2023-11-27
- feat: Updated packages. 2023-07-24
- feat: Added PipeApplication.StartAsync(args). 2023-02-27
🐞 Last 10 bug fixes:
- fix: Removed net6/net7. 2024-10-19
- fix: Small fixes for latest PR 2024-10-19
- fix: Updated System.Text.Json to 8.0.4 2024-09-17
- fix: Changed default formatter to SystemTextJsonFormatter. 2023-12-18
- fix: Fixed problems with $(BUILD_NUMBER). 2023-12-08
- test: Try to fix test for windows. 2023-12-08
- fix: Fixed bug with PipeStream.ReadAsync on non windows systems. 2023-05-26
- fix: Now EventExtensions is internal class. 2023-02-26
- fix: Fixed Connection.Disconnected unhandled exception bug. 2022-09-14
- fix: Fixed SemaphoreSlim usage. Fixes #24. 2022-08-26