我只想和大家分享一个解决方法，也许不是最漂亮的，但似乎很管用。我仍然有兴趣，如果有更好的方法来做这件事。
出版商：
发布者向redismqserver分配一个requestfilter，并在该方法中修改 .Body ，将 Package 器替换为实际请求。
出版商随后致电 .RegisterHandler 一次用于响应 Package 器类，然后按预期用于每个实际/实际处理程序。这将导致调用正确的服务处理程序：

public RedisClient(string name)
    {
        Name = name;
        redisFactory = new PooledRedisClientManager("localhost:6379");
        mqServer = new RedisMqServer(redisFactory, retryCount: 2);
        mqServer.RequestFilter = RequestFilter;
        // Response wrapper, ContainerResponse implements IProtocolContainer
        mqServer.RegisterHandler<ContainerResponse>(m => 
        {
            return m;
        });
        mqServer.RegisterHandler<GetSomething>(m =>
        {
            // m.Body is here an GetSomething
            return null;
        });
        mqServer.Start();
    }
    private ServiceStack.Messaging.IMessage RequestFilter(ServiceStack.Messaging.IMessage message)
    {
        if (message.Body is IProtocolContainer protocolContainer)
        {
            message.Body = protocolContainer.TheRequest;
        }
        return message;
    }
    public void AddMessage<T>(T theRequest) where T : CoreRequest
    {
        using (var mqClient = mqServer.CreateMessageQueueClient())
        {
            mqClient.Publish(new ContainerRequest(theRequest));
        }
    }
}

消费者：
同样的原则也适用于消费者：

public override void Configure(Container container)
    {
        container.Register(new ConsumerInfo() { Name = ServiceName });
        var redisFactory = new PooledRedisClientManager("localhost:6379");
        container.Register<IRedisClientsManager>(redisFactory);
        var mqHost = new RedisMqServer(redisFactory, retryCount: 2);
        mqHost.RequestFilter = RequestFilter;
        mqHost.ResponseFilter = ResponseFilter;
        mqHost.RegisterHandler<ContainerRequest>(base.ExecuteMessage);
        mqHost.RegisterHandler<GetSomething>(base.ExecuteMessage);
        mqHost.Start();
    }
    private object ResponseFilter(object arg)
    {
        return new ContainerResponse(arg as CoreRequest);
    }
    private ServiceStack.Messaging.IMessage RequestFilter(ServiceStack.Messaging.IMessage message)
    {
        if (message.Body is IProtocolContainer protocolContainer)
        {
            System.Diagnostics.Debug.WriteLine($"\tReplaced Body with {protocolContainer.TheRequest.GetType().Name}");
            message.Body = protocolContainer.TheRequest;
        }
        return message;
    }
}

servicestack mq消息工作流在文档中定义：

并解释了以下情况：

没有响应的邮件将发送到“.outq”主题

带有响应的消息将发布到response.inq

带有replyto的邮件的响应将发布到该地址

带异常的消息将重新尝试，然后发布到.dlq死信队列

因此，返回请求dto将其放入该请求dto的inq中，该请求dto将由注册来处理它的处理程序执行，在本例中，该处理程序恰好是自身，因此是循环。在redis mq服务中返回 null 或者 void 将其发布到redis的 transient /滚动响应dto.outq。