Гнездо JS Микросервис - Redis - Не подключается - PullRequest
Новая
       23

Гнездо JS Микросервис - Redis - Не подключается

0 голосов
/ 23 января 2020

Я тестирую с помощью Nest JS на микросервисах с использованием Redis. Я настроил код так, как предлагает документация, но когда я отправляю шаблон сообщения от клиента, мой Microservice не срабатывает.

Мой клиент - это API-интерфейс GraphQL Nest JS, который я хочу направить все запросы до.

Main.ts 

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  app.listen(3000);
}
bootstrap();

app.module.ts 

const REDIS_HOST = process.env.REDIS_HOST || 'localhost';
const REDIS_PORT = process.env.REDIS_PORT || 6379;

@Module({
  imports: [
    GraphQLModule.forRoot({
      autoSchemaFile: 'schema.gql',
      installSubscriptionHandlers: true,
      context: ({ req }) => {
        return {
          req
        }
      }
    }),
    TasksModule,
    TypeOrmModule.forRoot(typeOrmConfig),
    AuthModule,
    ClientsModule.register([{ name: 'TASK_SERVICE', transport: Transport.REDIS, options: { url: `redis://${REDIS_HOST}:${REDIS_PORT}` }}]),
  ]
})
export class AppModule {}

task.service.ts 

@Injectable()
export class TaskService {
    constructor(
        @Inject('TASK_SERVICE') private readonly client: ClientProxy
    ) { }

    async onModuleInit() {
        // Connect your client to the redis server on startup.
        await this.client.connect();
      }


    public async findAll() {
        const response = await this.client.send(
            { type: 'get-tasks' },
            { someImaginaryParams: 42 }
        ).toPromise();
        return response;
    }
}

Затем я создал Microservice API (который также использует GraphQL), который содержит следующее:

main. ts 

const REDIS_HOST = process.env.REDIS_HOST || '127.0.0.1';
const REDIS_PORT = process.env.REDIS_PORT || 6379;

const logger = new Logger('Main');

const microserviceOptions = {
  transport: Transport.REDIS,
  options: {
    url: `redis://${REDIS_HOST}:${REDIS_PORT}`
  }
}

async function bootstrap() {
  const app = await NestFactory.createMicroservice(AppModule, microserviceOptions);
  app.listen(() => {
    logger.log(`Microservice listening...`)
  });
}
bootstrap();

tasks.resolver.ts 

@Resolver(of => TaskDto)
export class TaskResolver {
    constructor(
        private readonly taskService: TaskService
    ) { }

    @Query(() => [TaskDto])
    @MessagePattern({ type: 'get-tasks' })
    async tasks() {
        console.log('Tasks API Hit - tasks');
        return await this.taskService.findAll();
    }
}

Таким образом, файл console.log, хранящийся в микросервисе, не ударил, и когда я проверяю это на GraphIQL, он просто никогда не возвращает ответ на запрос.

...