通过Spring-boot应用程序和生菜库在Redis中听一个队列

Question

我已经根据Spring-Boot，Spring-Cloud和Microservices Architecture开发了不同的服务，我也将以下依赖项（redis-client>：我

implementation 'io.lettuce:lettuce-core:6.1.5.RELEASE'

定义了redisbean>） 使用以下依赖关系。在春季如下：

@Configuration
public class RedisBean {
    @Bean
    public RedisClient redisClientFactory(AppConfig config) {
        var client =  RedisClient.create(config.getRedis());
        client.setDefaultTimeout(Duration.ZERO);
        return client;
    }

    @Bean
    @Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
    public StatefulRedisConnection<byte[], byte[]> redisConnectionFactory(RedisClient client) {
        return client.connect(ByteArrayCodec.INSTANCE);
    }

    @Bean
    public RedisCommands<byte[], byte[]> redisCommands(StatefulRedisConnection<byte[], byte[]> connection) {
        return connection.sync();
    }
}

我有sso和Accounting服务。

在我的sso服务中，当用户寄存器时，我将在queue中按照这样的用户名：

@Service
public class AccountingServiceImpl implements AccountingService {

    private final RedisCommands<byte[], byte[]> redis;
    private final AppConfig appConfig;

    public AccountingServiceImpl(AppConfig appConfig, RedisCommands<byte[], byte[]> redis) {
        this.redis = redis;
        this.appConfig = appConfig;
    }

    @Override
    public void requestCreateDefaultAccount(String username) {
        redis.rpush(
                appConfig.getCreateAccountQueueName().getBytes(StandardCharsets.UTF_8)
                , username.getBytes(StandardCharsets.UTF_8)
        );
    }
}

现在：现在在Accounting服务中，我想定期收听已注册的Queue，并且只要按下用户名，我就会使用它并为用户创建一个默认帐户。

我已经搜索了很多东西，但找不到适合我的要求的解决方案，使用io.lettuce：生菜核库。

任何帮助将不胜感激！！