EasyNetQ .NET（开发者用法）

EasyNetQ 提供了一种直接的方法来将消息总线发布到队列中。 您定义消息总线结构（通常是作为类）并使用 PublishAsync 方法发送消息实例：

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using EasyNetQ;

public class OrderMessage
{
    public int OrderId { get; set; }
    public string CustomerName { get; set; }
    public List<Product> Items { get; set; }
}

public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    public Product(int id, string name)
    {
        Id = id;
        Name = name;
    }
}

class Program
{
    static async Task Main(string[] args)
    {
        // Assume the bus connection is established
        var bus = RabbitHutch.CreateBus("host=localhost");

        // Publish an order message to the message bus
        await bus.PubSub.PublishAsync(new OrderMessage
        {
            OrderId = 123,
            CustomerName = "John Doe",
            Items = new List<Product>
            {
                new Product(1, "Product A"),
                new Product(2, "Product B")
            }
        });
    }
}

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using EasyNetQ;

public class OrderMessage
{
    public int OrderId { get; set; }
    public string CustomerName { get; set; }
    public List<Product> Items { get; set; }
}

public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    public Product(int id, string name)
    {
        Id = id;
        Name = name;
    }
}

class Program
{
    static async Task Main(string[] args)
    {
        // Assume the bus connection is established
        var bus = RabbitHutch.CreateBus("host=localhost");

        // Publish an order message to the message bus
        await bus.PubSub.PublishAsync(new OrderMessage
        {
            OrderId = 123,
            CustomerName = "John Doe",
            Items = new List<Product>
            {
                new Product(1, "Product A"),
                new Product(2, "Product B")
            }
        });
    }
}

代码描述

代码定义了一个名为 OrderMessage 的类，表示由客户下的订单。 它有三个属性：OrderId（整数）、CustomerName（字符串）和 Items（Product 对象的列表）。

然后代码模拟发布一个 OrderMessage 实例，以通过 PublishAsync 方法将订单 ID 为 123、客户名称为 "John Doe"，以及两个项目 "Product A" 和 "Product B" 的消息发送到消息总线。 这个消息总线可能是一个用于将消息分发给感兴趣方的系统。

使用 PubSub 模式异步订阅和处理消息

using System;
using System.Threading.Tasks;
using EasyNetQ;

class Program
{
    static async Task Main(string[] args)
    {
        // Assume the bus connection is established
        var bus = RabbitHutch.CreateBus("host=localhost");

        // Subscribe to the queue for order messages asynchronously
        await bus.PubSub.SubscribeAsync<OrderMessage>("orders", async msg =>
        {
            Console.WriteLine($"Processing order: {msg.OrderId} for {msg.CustomerName}");
            // Implement your business logic to process the order
        });
    }
}

using System;
using System.Threading.Tasks;
using EasyNetQ;

class Program
{
    static async Task Main(string[] args)
    {
        // Assume the bus connection is established
        var bus = RabbitHutch.CreateBus("host=localhost");

        // Subscribe to the queue for order messages asynchronously
        await bus.PubSub.SubscribeAsync<OrderMessage>("orders", async msg =>
        {
            Console.WriteLine($"Processing order: {msg.OrderId} for {msg.CustomerName}");
            // Implement your business logic to process the order
        });
    }
}

代码使用 EasyNetQ 的 SubscribeAsync 方法异步订阅 OrderMessage 的队列。 收到消息后，它通过将 OrderId 和 CustomerName 输出到控制台来处理消息。 该订阅允许通过自定义业务逻辑进行进一步处理。

EasyNetQ 扩展了其能力，超越了 pub/sub 模式，还支持其他消息传递范式：

• 请求-回复 (RPC)： 这种模式支持双向通信，客户端发送请求消息并等待来自 RPC 服务器的响应。 订阅者还可以在处理之前检查接收到的消息属性。
• 主题： 订阅者无需订阅特定队列，可以表示对主题的兴趣，可以根据路由键路由消息。

从HTML生成PDF

使用 IronPDF 从 HTML 创建 PDF 非常简单。 以下是如何将基本 HTML 字符串转换为 PDF 的示例：

using IronPdf;

namespace Demo
{
    internal class PDF
    {
        public static void GeneratePDF()
        {
            // Set the license key for IronPDF
            IronPdf.License.LicenseKey = "Your-License Key Here";

            // Define the HTML content
            var htmlContent = "<h1>Hello EasyNetQ, IronPDF!</h1>";

            // Create a renderer using Chrome's engine
            var renderer = new ChromePdfRenderer();

            // Generate a PDF from the HTML string
            var pdf = renderer.RenderHtmlAsPdf(htmlContent);

            // Save the PDF as a file
            pdf.SaveAs("output.pdf");
        }
    }
}

using IronPdf;

namespace Demo
{
    internal class PDF
    {
        public static void GeneratePDF()
        {
            // Set the license key for IronPDF
            IronPdf.License.LicenseKey = "Your-License Key Here";

            // Define the HTML content
            var htmlContent = "<h1>Hello EasyNetQ, IronPDF!</h1>";

            // Create a renderer using Chrome's engine
            var renderer = new ChromePdfRenderer();

            // Generate a PDF from the HTML string
            var pdf = renderer.RenderHtmlAsPdf(htmlContent);

            // Save the PDF as a file
            pdf.SaveAs("output.pdf");
        }
    }
}

上面的代码片段显示了如何使用 IronPDF 创建 PDF。 它设置了许可证密钥，定义了一些示例 HTML 内容，使用 Chrome 的引擎创建了一个渲染器，将 HTML 转换为 PDF 文档，最后将该 PDF 保存为 "output.pdf"。