什么是 StreamJsonRpc？

StreamJsonRpc 是一个跨平台库，旨在使用轻量且高效的线协议促进远程过程调用 (RPC)。 它利用支持各种通信通道的底层传输机制，如 TCP/IP、命名管道和 HTTP。该库利用 .NET 事件来处理传入的请求和响应，提供了一种强大的异步通信机制。 开发人员可以附加方法实现以处理 RPC 请求，并使用 StreamJsonRpc API 定义自定义行为。 StreamJsonRpc 作为 .NET Portable Library 提供，确保跨不同平台的兼容性，并可无缝集成到各种 .NET 应用程序中。

StreamJsonRpc 的一个关键特点是对双向通信的强大支持，包括通知和进度报告。 通过支持包括 HTTP、命名管道和 TCP/IP 在内的各种传输协议，它为程序提供了更多的通信选项。 StreamJsonRpc 处理 JSON-RPC 消息的序列化和反序列化，确保跨多个平台和支持 JSON 的计算机语言的兼容性。

StreamJsonRpc 旨在考虑性能和可扩展性。 它兼容现有的 C# 程序，可以用于构建客户端-服务器应用程序、微服务架构、分布式系统以及其他需要可靠和高效通信的应用程序。 在 C# 项目中集成远程过程调用时，开发人员倾向于选择它，因为它具有可靠性和易用性。

创建和配置 StreamJsonRpc C

必须设置一个客户端和一个服务器，以便在 C# 应用程序中创建和配置 StreamJsonRpc。 每个部分的详细说明如下：

dotnet new console -n StreamjsonrpcExample
cd StreamjsonrpcExample

dotnet new console -n StreamjsonrpcExample
cd StreamjsonrpcExample

dotnet add package StreamJsonRpc

dotnet add package StreamJsonRpc

using Microsoft.AspNetCore.Hosting;
using StreamJsonRpc;
using System;
using System.Threading.Tasks;

public class MyService
{
    // Asynchronous method to add two integers
    public Task<int> AddAsync(int a, int b)
    {
        return Task.FromResult(a + b);
    }

    // Asynchronous method to greet a user
    public Task<string> GreetAsync(string name)
    {
        return Task.FromResult($"Hello, {name}!");
    }
}

class Program
{
    static void Main(string[] args)
    {
        // Initialize the service offering RPC methods
        var service = new MyService();

        // Create a StreamJsonRpc server listening on websockets
        var jsonRpc = new JsonRpc(new ServerWebSocketJsonRpcMessageHandler("ws://localhost:8080"));

        // Add service as RPC target
        jsonRpc.AddLocalRpcTarget(service);

        // Start listening for incoming JSON-RPC requests
        jsonRpc.StartListening();

        Console.WriteLine("JsonRpc server listening on ws://localhost:8080");
        Console.WriteLine("Press any key to stop the server...");

        // Wait for user input to stop the server
        Console.ReadKey();

        // Dispose resources when done
        jsonRpc.Dispose();
    }
}

using Microsoft.AspNetCore.Hosting;
using StreamJsonRpc;
using System;
using System.Threading.Tasks;

public class MyService
{
    // Asynchronous method to add two integers
    public Task<int> AddAsync(int a, int b)
    {
        return Task.FromResult(a + b);
    }

    // Asynchronous method to greet a user
    public Task<string> GreetAsync(string name)
    {
        return Task.FromResult($"Hello, {name}!");
    }
}

class Program
{
    static void Main(string[] args)
    {
        // Initialize the service offering RPC methods
        var service = new MyService();

        // Create a StreamJsonRpc server listening on websockets
        var jsonRpc = new JsonRpc(new ServerWebSocketJsonRpcMessageHandler("ws://localhost:8080"));

        // Add service as RPC target
        jsonRpc.AddLocalRpcTarget(service);

        // Start listening for incoming JSON-RPC requests
        jsonRpc.StartListening();

        Console.WriteLine("JsonRpc server listening on ws://localhost:8080");
        Console.WriteLine("Press any key to stop the server...");

        // Wait for user input to stop the server
        Console.ReadKey();

        // Dispose resources when done
        jsonRpc.Dispose();
    }
}

Imports Microsoft.AspNetCore.Hosting
Imports StreamJsonRpc
Imports System
Imports System.Threading.Tasks

Public Class MyService
	' Asynchronous method to add two integers
	Public Function AddAsync(ByVal a As Integer, ByVal b As Integer) As Task(Of Integer)
		Return Task.FromResult(a + b)
	End Function

	' Asynchronous method to greet a user
	Public Function GreetAsync(ByVal name As String) As Task(Of String)
		Return Task.FromResult($"Hello, {name}!")
	End Function
End Class

Friend Class Program
	Shared Sub Main(ByVal args() As String)
		' Initialize the service offering RPC methods
		Dim service = New MyService()

		' Create a StreamJsonRpc server listening on websockets
		Dim jsonRpc As New JsonRpc(New ServerWebSocketJsonRpcMessageHandler("ws://localhost:8080"))

		' Add service as RPC target
		jsonRpc.AddLocalRpcTarget(service)

		' Start listening for incoming JSON-RPC requests
		jsonRpc.StartListening()

		Console.WriteLine("JsonRpc server listening on ws://localhost:8080")
		Console.WriteLine("Press any key to stop the server...")

		' Wait for user input to stop the server
		Console.ReadKey()

		' Dispose resources when done
		jsonRpc.Dispose()
	End Sub
End Class

using StreamJsonRpc;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        // Create a JSON-RPC client connected to the WebSocket server endpoint
        var proxy = new JsonRpc(new ClientWebSocketJsonRpcMessageHandler("ws://localhost:8080"));

        // Start listening for incoming messages from the server
        await proxy.StartListeningAsync();

        // Invoke the AddAsync method on the server
        var resultAdd = await proxy.InvokeAsync<int>("AddAsync", 10, 20);
        Console.WriteLine($"AddAsync result: {resultAdd}");

        // Invoke the GreetAsync method on the server
        var resultGreet = await proxy.InvokeAsync<string>("GreetAsync", "John");
        Console.WriteLine($"GreetAsync result: {resultGreet}");

        // Dispose the proxy when done
        proxy.Dispose();
    }
}

using StreamJsonRpc;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        // Create a JSON-RPC client connected to the WebSocket server endpoint
        var proxy = new JsonRpc(new ClientWebSocketJsonRpcMessageHandler("ws://localhost:8080"));

        // Start listening for incoming messages from the server
        await proxy.StartListeningAsync();

        // Invoke the AddAsync method on the server
        var resultAdd = await proxy.InvokeAsync<int>("AddAsync", 10, 20);
        Console.WriteLine($"AddAsync result: {resultAdd}");

        // Invoke the GreetAsync method on the server
        var resultGreet = await proxy.InvokeAsync<string>("GreetAsync", "John");
        Console.WriteLine($"GreetAsync result: {resultGreet}");

        // Dispose the proxy when done
        proxy.Dispose();
    }
}

Imports StreamJsonRpc
Imports System
Imports System.Threading.Tasks

Friend Class Program
	Shared Async Function Main(ByVal args() As String) As Task
		' Create a JSON-RPC client connected to the WebSocket server endpoint
		Dim proxy = New JsonRpc(New ClientWebSocketJsonRpcMessageHandler("ws://localhost:8080"))

		' Start listening for incoming messages from the server
		Await proxy.StartListeningAsync()

		' Invoke the AddAsync method on the server
		Dim resultAdd = Await proxy.InvokeAsync(Of Integer)("AddAsync", 10, 20)
		Console.WriteLine($"AddAsync result: {resultAdd}")

		' Invoke the GreetAsync method on the server
		Dim resultGreet = Await proxy.InvokeAsync(Of String)("GreetAsync", "John")
		Console.WriteLine($"GreetAsync result: {resultGreet}")

		' Dispose the proxy when done
		proxy.Dispose()
	End Function
End Class

开始

通过将 StreamJsonRpc 与 IronPDF 集成，并使用通过 JSON-RPC 查询交换的数据，可以在 C# 应用程序中动态生成 PDF 页面。 以下是设置 IronPDF 和 StreamJsonRpc 的基本操作：

什么是 IronPDF？ [IronPDF](/) 可被 C# 程序用于创建、读取和编辑 PDF 文档。 这一工具让开发者能简单地将HTML、CSS和JavaScript信息转换为可打印的、高质量的PDF文件。 关键任务包括添加标题和页脚、拆分和合并 PDF、为文档添加水印和将 HTML 转换为 PDF。 IronPDF 因为支持 .NET Framework 和 .NET Core 对于各种应用程序很有帮助。 由于 PDF 易于使用且提供丰富的内容，开发人员可以轻松地将它们集成到产品中。 由于 IronPDF 能够轻松处理复杂的布局和格式化，生成的输出 PDF 几乎与原始 HTML 文本相匹配。  ### IronPDF的功能 **从HTML生成PDF** 将JavaScript、HTML和CSS转换为PDF。 IronPDF 支持媒体查询和响应式设计这两个现代 Web 标准。 它是用于使用 HTML 和 CSS 动态装饰 PDF 文档、报告和账单的有用工具。 **PDF编辑** 可以将文本、照片和其他内容添加到现有 PDF 中。 从 PDF 文件中提取文本和图像。 开发人员可以将多个 PDF 合并为一个文件，或将 PDF 文件分割为多个独立文件。 添加水印、注释、标题和页脚。 **PDF转换** 可以将多种文件格式（包括 Word、Excel 和图像文件）转换为 PDF。 您还可以进行 PDF 到图像的转换（PNG、JPEG 等）。 **性能和可靠性** 在工业环境中，高性能和可靠性是理想的设计特性。 IronPDF 可以轻松管理大型文档集。 ### 安装IronPDF 为了在.NET项目中获得处理PDF所需的工具，请安装IronPDF包。 ```sh dotnet add package IronPdf ``` ### StreamJsonRpc 与 IronPDF #### 创建服务类 在服务类 `PdfService.cs` 中提供将从接收到的数据创建 PDF 的方法。 作为示例： ```csharp using IronPdf; using System.IO; using System.Threading.Tasks; public class PdfService { // Asynchronously generates a PDF from HTML content public async Task GeneratePdfAsync(string htmlContent) { var renderer = new ChromePdfRenderer(); var pdf = renderer.RenderHtmlAsPdf(htmlContent); return await pdf.BinaryDataAsync(); } } ``` #### 配置 StreamJsonRpc 服务器 使用 `Program.cs` 作为服务器上 StreamJsonRpc 的接口，通过流 JSON-RPC 提供 `GeneratePdfAsync` 方法： ```csharp using StreamJsonRpc; using System; using System.Net.WebSockets; using System.Threading.Tasks; class Program { static async Task Main(string[] args) { // Initialize PdfService which generates PDFs var service = new PdfService(); // Create JSON-RPC server listening on websockets var jsonRpc = new JsonRpc(new WebSocketRpcServerMessageHandler(new Uri("ws://localhost:8080"))); // Add the PdfService as an RPC target jsonRpc.AddLocalRpcTarget(service); // Start listening for incoming JSON-RPC requests jsonRpc.StartListening(); Console.WriteLine("JsonRpc server listening on ws://localhost:8080"); Console.WriteLine("Press any key to stop the server..."); // Wait for user input to stop the server Console.ReadKey(); // Gracefully stop listening and dispose resources when done await jsonRpc.StopListeningAsync(); jsonRpc.Dispose(); } } ```  #### 创建 IronPDF 客户端 要连接到服务器并请求创建 PDF，请实现 StreamJsonRpc 客户端（`ClientProgram.cs`）： ```csharp using StreamJsonRpc; using System; using System.Net.WebSockets; using System.Text; using System.Threading.Tasks; using System.IO; class ClientProgram { static async Task Main(string[] args) { // Create JSON-RPC client connected to WebSocket server endpoint var proxy = new JsonRpc(new WebSocketRpcClientMessageHandler(new Uri("ws://localhost:8080"))); // Start listening for incoming messages from the server await proxy.StartListeningAsync(); // Example HTML content string htmlContent = "

Hello, IronPDF!

"; // Invoke GeneratePdfAsync method on the server var pdfBytes = await proxy.InvokeAsync("GeneratePdfAsync", htmlContent); // Save the resulted PDF to a file File.WriteAllBytes("GeneratedPdf.pdf", pdfBytes); Console.WriteLine("PDF generated: GeneratedPdf.pdf"); // Dispose the proxy when done proxy.Dispose(); } } ``` `PdfService.cs` 类是 StreamJsonRpc 服务器实现的基本部分，它使 C# 应用程序更容易使用 IronPDF 生成 PDF 文档。 通过利用 IronPDF 的 `RenderHtmlAsPdf`，这个服务类包含了处理 HTML 内容转换为 PDF 格式的方法。 通过异步任务方法 `GeneratePdfAsync` (`async Task GeneratePdfAsync(string htmlContent)`) 接受 HTML 内容作为输入。 该方法创建一个 `ChromePdfRenderer` 实例来执行转换，通过 `RenderHtmlAsPdf(htmlContent)` 生成一个 PDF 文档。 生成的 PDF 的二进制数据随后被异步检索（`pdf.BinaryDataAsync()`），然后作为 `byte[]` 数组返回数据。  此方法保证快速和响应式的 PDF 生成，适用于需要快速生成文档的应用程序。 PDF 生成逻辑被包含在 `PdfService.cs` 中，使开发人员可以轻松集成并通过 StreamJsonRpc 公开此功能。 这允许远程客户端在保持其服务器端设计的模块化和清晰度的情况下平稳地调用 PDF 生成任务。  ## 结论 综上所述，通过将 StreamJsonRpc 与 IronPDF 结合使用，开发人员可以创建可靠且高效的 .NET 应用程序，这些应用程序支持远程过程调用 (RPC) 并利用强大的 PDF 生成功能。 使用 JSON-RPC，一种远程过程调用的轻量协议，StreamJsonRpc 能够在客户端和服务器组件之间实现流畅的通信。 开发人员可以将此功能与 IronPDF 结合使用，从这些远程调用的结果中生成动态、数据驱动的 PDF。 在准备报告、发票或任何其他需要表示最新数据可用性的文档时，这种集成特别有帮助，因为它允许实时数据检索和 PDF 输出。 这些技术的集成优化了开发过程、提高了性能，并增强了应用程序有效地满足复杂业务需求的能力。 借助 IronPDF 和 [Iron 软件开发工具](https://ironsoftware.com)，开发者可以以 $799 的起始价格更快捷地创建更多的 Web 应用程序和功能。 它通过将其核心概念与高度灵活的 Iron 软件工具箱相结合实现这一目标。 如果与项目相关的所有许可选项都得到了清晰的描述，开发人员会更容易选择最佳的型号。 上述的优点使得开发人员能够更及时、有序和高效地为一系列问题创建解决方案。