MqConfig config = new MqConfig()
{
    HostName = "xxx",
    Port = xxx,
    UserName = "xxx",
    Password = "xxx",
    ExchangeName = "xxx",
    vHost = "xxx",
    PrefetchCount = 1,
    AutoAck = false,
    IsDebug = false,
};
MqGlobleConfig.InitDefaultConnection(config);

MqChannelManager channelManager = new MqChannelManager();
//创建消费者
var receiveChannel = channelManager.CreateReceiveChannel("xxx", async x =>
{
    Log.Information($"receive => {x.Content}");
    x.BasicAck();//手动回答
});
//创建生产者
var producerChannel = channelManager.CreatePublishChannel("xxx");
//单个
producerChannel.Publish("xxx");
//批量
producerChannel.BatchPublish(Enumerable.Range(1, 10000).Select(x => "xxx"));
Thread.Sleep(-1);
producerChannel.Stop();

//在配置文件添加节点mongo
public class MongoConfig
{
    public const string SectionName = "mongo";
    /// <summary>
    /// 数据库连接串
    /// </summary>
    [Required]
    public string Connection { get; set; }
    /// <summary>
    /// 数据库名称
    /// </summary>
    [Required]
    public string DatabaseName { get; set; }
    /// <summary>
    /// 仓储所在的程序集名称,非必填项,默认启动时会自动发现仓储类并注册
    /// </summary>
    public List<string> RepositoryAssemblyNames { get; set; }
}

//注册服务
services.AddMongoHelperz(Configuration);

//定义实体
public class SysParams : MongoEntity
{
    public string code { get; set; }
    public string value { get; set; }
}
//定义单例仓储,用于集合名称固定的
public class SysParamsRepository : MongoRepository<SysParams>
{

}
//定义多例仓储,用于集合名称不固定(分表)
public class SysParamsRepository : TransientMongoRepository<SysParams>
{
    public AliUserDataRepository(IMongoDatabase mongoDatabase) : base(mongoDatabase, "_xxxx")
    {
    }
    public override void SetCollectionName(Func<string> configure)
    {
        //编辑集合名称
        GetCollectionName = () => $"{configure()}{_collectionName}";
    }
}