Flynk.Net.Services.Transmit.Grpc.Client 1.1.1

Flynk.Net.Services.Transmit.Grpc.Client

Lightweight gRPC client library for the Flynk Transmission Service. Provides typed RPC communication with routing, serialization, and reconnection support.

Features

• Typed request/response handling with automatic JSON serialization
• Route-based message handlers
• Built-in reconnection with configurable settings
• Service discovery via Info endpoint
• Echo endpoint for connectivity testing
• No ASP.NET Core dependencies - ideal for mobile, desktop, and microservice clients

Installation

dotnet add package Flynk.Net.Services.Transmit.Grpc.Client

Quick Start

using Flynk.Net.Services.Transmit.Grpc.Client;
using Microsoft.Extensions.Logging;

// Create logger
var loggerFactory = LoggerFactory.Create(b => b.AddConsole());
var logger = loggerFactory.CreateLogger<RpcClient>();

// Create client
using var client = new RpcClient(
    address: "http://localhost:5001",
    clientId: "my-client",
    logger: logger
);

// Send request to server (no recipientId = routes to server)
var response = await client.Send<PingRequest, PingResponse>(
    route: "ping",
    request: new PingRequest { Message = "Hello!" }
);

if (response.IsOK)
{
    Console.WriteLine($"Server replied: {response.Payload.Message}");
}

Receiving Messages

Register handlers to receive and process incoming requests:

// Register a typed handler
client.RegisterRoute<OrderRequest, OrderResponse>("order.create",
    async (request, metadata) =>
    {
        var order = ProcessOrder(request);
        return Response<OrderResponse>.OK(order);
    });

// Start listening for incoming messages
client.StartListening();

// Keep running...
Console.ReadLine();

// Cleanup
client.StopListening();

Configuration

var settings = new RpcClientSettings
{
    EnableReconnection = true,          // Auto-reconnect on disconnect
    ReconnectionDelaySeconds = 5,       // Wait between attempts
    MaxReconnectionAttempts = 10        // Use -1 for unlimited
};

var client = new RpcClient(
    address: "http://localhost:5001",
    clientId: "my-client",
    logger: logger,
    settings: settings
);

Custom JSON Serialization

var jsonOptions = new JsonSerializerOptions
{
    PropertyNameCaseInsensitive = true,
    PropertyNamingPolicy = JsonNamingPolicy.CamelCase
};

var client = new RpcClient(
    address: "http://localhost:5001",
    clientId: "my-client",
    logger: logger,
    jsonOptions: jsonOptions
);

Built-in System Routes

// Get information about another client
var info = await client.Info("target-client-id");
// Returns: ClientId, MachineName, OSVersion, ProcessId, CLRVersion, RegisteredRoutes

// Test connectivity with echo
var echo = await client.Echo("target-client-id", "test message");

Response Handling

// Success responses
return Response<MyResponse>.OK(payload);
return Response<MyResponse>.OK(payload, "Optional message");

// Failure responses
return Response<MyResponse>.FAILED("Error description");

Class-Based Handlers

public class OrderHandler : TypedRouteHandler<OrderRequest, OrderResponse>
{
    protected override async Task<Response<OrderResponse>> HandleTypedAsync(
        OrderRequest request,
        Dictionary<string, string> metadata)
    {
        var order = await ProcessOrder(request);
        return Response<OrderResponse>.OK(order);
    }
}

// Register
client.RegisterRouteHandler("order.create", new OrderHandler());

Server Package

For hosting the gRPC server, install the companion package:

dotnet add package Flynk.Net.Services.Transmit.Grpc.Server

See the Server package documentation for setup instructions.

License

This software is licensed under the Flynk Freeware License.