RMQ 和 TypeOrm Nestjs 冲突

Question

我使用TypeOrm时发生冲突=> RMQ崩溃 不知道为什么。

使用库 golevelup/nestjs-rabbitmq 我在这个问题上浪费了7个小时..

@Module({
    imports: [
        ConfigModule.forRoot({
            isGlobal: true,
            envFilePath: process.env.NODE_ENV === 'production' ? '.env.production' : '.env.development',
        }),
        HttpModule,
        TypeOrmModule.forRootAsync({
            imports: [ConfigModule],
            useFactory: (configService: ConfigService) => ({
                type: 'postgres',
                host: configService.get<string>('DB_HOST', 'postgres'),
                port: parseInt(configService.get<string>('DB_PORT', '5432'), 10),
                username: configService.get<string>('DB_USERNAME', 'your_pgsql_username'),
                password: configService.get<string>('DB_PASSWORD', 'your_pgsql_password'),
                database: configService.get<string>('DB_DATABASE', '404sq'),
                entities: [UserData, UserProfile],
                synchronize: true,
                migrationsRun: true,
                migrations: [CreateDatabase1619811671274],
            }),
            inject: [ConfigService],
        }),
        RabbitMQModule.forRoot(RabbitMQModule, {
            exchanges: [
                {
                    name: 'AUTH',
                    type: 'topic',
                },
            ],
            uri: 'amqp://your_rabbitmq_username:your_rabbitmq_password@rabbitmq:5672',
        }),
        SignUpModule,
        SignInModule,
    ],
  
})
export class AppModule {}

承诺线路

创建模块

创建服务

Answer 1

我不太确定你想要实现什么。

但是，如果您尝试使用某种 RabbitMQ 客户端，则可以使用我的 @nestjs/microservices 提供的 ClientsModule。