区块链链游系统开发方案解析及（成熟代码）

DAPP的底层区块链开发平台，就像手机的iOS和Android系统一样，是各种DAPP的潜在生态环境。DApp是源自底层区块链平台生态的各种分布式应用程序，也是区块链世界中的基本服务提供商。Dapp在区块链中，就像应用程序在iOS和Android中一样。

dapps/0599a6100280df0d296653e89177b9011304d971fb98aba3edcc5b937c4183fb/

☆--块链。db//app数据库文件与主链中的数据分开存储

☆--配置。json//应用程序的节点配置文件目前主要用于配置受托方的密钥

☆-合同/合同目录

│L——域的实现代码。js//域名合同

☆--短小精悍。json//用于注册dapp的图元文件

☆-开端json//Genesis块

☆--初始化。js//应用程序初始化代码，可用于某些设置、事件注册等

☆-interface//查询接口的实现目录

│☆--域的实现。js//域名查询接口

│└──你好世界.js

☆--logs//日志目录

基于worker模板创建一个基础项目：dotnet new worker -n MassTransit.Demo
打开项目，添加NuGet包：MassTransit
定义订单创建事件消息契约：
using System;

namespace MassTransit.Demo
{

public record OrderCreatedEvent
{
    public Guid OrderId { get; set; }
}

}
复制
修改Worker类，发送订单创建事件：
namespace MassTransit.Demo;

public class Worker : BackgroundService
{

readonly IBus _bus;//注册总线
public Worker(IBus bus)
{
    _bus = bus;
}
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
        //模拟并发送订单创建事件
        await _bus.Publish(new OrderCreatedEvent(Guid.NewGuid()), stoppingToken);
        await Task.Delay(1000, stoppingToken);
    }
}

}
复制
仅需实现IConsumer泛型接口，即可实现消息的订阅：
public class OrderCreatedEventConsumer: IConsumer
{

private readonly ILogger<OrderCreatedEventConsumer> _logger;
public OrderCreatedEventConsumer(ILogger<OrderCreatedEventConsumer> logger)
{
    _logger = logger;
}
public Task Consume(ConsumeContext<OrderCreatedEvent> context)
{
    _logger.LogInformation($"Received Order:{context.Message.OrderId}");
    return Task.CompletedTask;
}

}
复制
注册服务：
using MassTransit;
using MassTransit.Demo;

IHost host = Host.CreateDefaultBuilder(args)

.ConfigureServices(services =>
{
    services.AddHostedService<Worker>();
    services.AddMassTransit(configurator =>
    {
        //注册消费者
        configurator.AddConsumer<OrderCreatedEventConsumer>();
        //使用基于内存的消息路由传输
        configurator.UsingInMemory((context, cfg) =>
        {
            cfg.ConfigureEndpoints(context);
        });
    });
})
.Build();

await host.RunAsync();
复制
运行项目，一个简单的进程内事件发布订阅的应用就完成了。
如果需要使用RabbitMQ 消息代理进行消息传输，则仅需安装MassTransit.RabbitMQNuGet包，然后指定使用RabbitMQ 传输消息即可。

using MassTransit;
using MassTransit.Demo;

IHost host = Host.CreateDefaultBuilder(args)

.ConfigureServices(services =>
{
    services.AddHostedService<Worker>();
    services.AddMassTransit(configurator =>
    {
        configurator.AddConsumer<OrderCreatedEventConsumer>();
        
        // configurator.UsingInMemory((context, cfg) =>
        // {
        //     cfg.ConfigureEndpoints(context);
        // });
        
        configurator.UsingRabbitMq((context, cfg) =>
        {
            cfg.Host(
                host: "localhost",
                port: 5672,
                virtualHost: "/",
                configure: hostConfig =>
                {
                    hostConfig.Username("guest");
                    hostConfig.Password("guest");
                });
            cfg.ConfigureEndpoints(context);
        });
    });
})
.Build();

await host.RunAsync();