From 3ba970474117252965b78bc264167a3ea6eb5088 Mon Sep 17 00:00:00 2001 From: mozzie Date: Tue, 10 Oct 2023 21:38:59 +0800 Subject: [PATCH] fear: nats log promihous --- apps/services/aorta/gateway/src/app.module.ts | 10 ++++++---- apps/services/aorta/gateway/src/auth/auth.module.ts | 10 ++++++---- apps/services/aorta/report/src/main.ts | 10 ++++++---- apps/services/cert/authenticate/src/main.ts | 10 ++++++---- apps/services/cert/authorize/src/main.ts | 10 ++++++---- apps/services/cert/gateway/src/admin/admin.module.ts | 10 ++++++---- apps/services/cert/gateway/src/app.module.ts | 10 ++++++---- apps/services/dicom/src/main.ts | 10 ++++++---- apps/services/dmp/archive/src/main.ts | 10 ++++++---- apps/services/dmp/gateway/src/admin/admin.module.ts | 10 ++++++---- .../dmp/gateway/src/annotator/annotator.module.ts | 10 ++++++---- apps/services/dmp/gateway/src/app.module.ts | 10 ++++++---- apps/services/dmp/gateway/src/dicom/dicom.module.ts | 10 ++++++---- apps/services/logger/src/main.ts | 10 ++++++---- docker-compose.rabbit.yml | 6 ++++++ 15 files changed, 90 insertions(+), 56 deletions(-) diff --git a/apps/services/aorta/gateway/src/app.module.ts b/apps/services/aorta/gateway/src/app.module.ts index 6683067..a2faee2 100644 --- a/apps/services/aorta/gateway/src/app.module.ts +++ b/apps/services/aorta/gateway/src/app.module.ts @@ -27,11 +27,13 @@ import { ForbiddenExceptionFilter } from './filter/forbid.filter'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/aorta/gateway/src/auth/auth.module.ts b/apps/services/aorta/gateway/src/auth/auth.module.ts index 5dc2212..85061a7 100644 --- a/apps/services/aorta/gateway/src/auth/auth.module.ts +++ b/apps/services/aorta/gateway/src/auth/auth.module.ts @@ -8,11 +8,13 @@ import { ClientsModule, Transport } from '@nestjs/microservices'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/aorta/report/src/main.ts b/apps/services/aorta/report/src/main.ts index 14a0dc7..1f6619d 100644 --- a/apps/services/aorta/report/src/main.ts +++ b/apps/services/aorta/report/src/main.ts @@ -6,11 +6,13 @@ async function bootstrap() { const app = await NestFactory.createMicroservice( AppModule, { - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], // 可以指定链接到多个nats的消息队列 - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ); diff --git a/apps/services/cert/authenticate/src/main.ts b/apps/services/cert/authenticate/src/main.ts index 14a0dc7..1f6619d 100644 --- a/apps/services/cert/authenticate/src/main.ts +++ b/apps/services/cert/authenticate/src/main.ts @@ -6,11 +6,13 @@ async function bootstrap() { const app = await NestFactory.createMicroservice( AppModule, { - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], // 可以指定链接到多个nats的消息队列 - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ); diff --git a/apps/services/cert/authorize/src/main.ts b/apps/services/cert/authorize/src/main.ts index c39ffab..546d18a 100644 --- a/apps/services/cert/authorize/src/main.ts +++ b/apps/services/cert/authorize/src/main.ts @@ -6,11 +6,13 @@ async function bootstrap() { const app = await NestFactory.createMicroservice( AppModule, { - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], // 可以指定链接到多个nats的消息队列 - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ); diff --git a/apps/services/cert/gateway/src/admin/admin.module.ts b/apps/services/cert/gateway/src/admin/admin.module.ts index 412111f..23df24c 100644 --- a/apps/services/cert/gateway/src/admin/admin.module.ts +++ b/apps/services/cert/gateway/src/admin/admin.module.ts @@ -8,11 +8,13 @@ import { ClientsModule, Transport } from '@nestjs/microservices'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/cert/gateway/src/app.module.ts b/apps/services/cert/gateway/src/app.module.ts index 76fa6a5..02d5c0c 100644 --- a/apps/services/cert/gateway/src/app.module.ts +++ b/apps/services/cert/gateway/src/app.module.ts @@ -21,11 +21,13 @@ import { AdminModule } from './admin/admin.module'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/dicom/src/main.ts b/apps/services/dicom/src/main.ts index 14a0dc7..1f6619d 100644 --- a/apps/services/dicom/src/main.ts +++ b/apps/services/dicom/src/main.ts @@ -6,11 +6,13 @@ async function bootstrap() { const app = await NestFactory.createMicroservice( AppModule, { - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], // 可以指定链接到多个nats的消息队列 - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ); diff --git a/apps/services/dmp/archive/src/main.ts b/apps/services/dmp/archive/src/main.ts index 14a0dc7..1f6619d 100644 --- a/apps/services/dmp/archive/src/main.ts +++ b/apps/services/dmp/archive/src/main.ts @@ -6,11 +6,13 @@ async function bootstrap() { const app = await NestFactory.createMicroservice( AppModule, { - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], // 可以指定链接到多个nats的消息队列 - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ); diff --git a/apps/services/dmp/gateway/src/admin/admin.module.ts b/apps/services/dmp/gateway/src/admin/admin.module.ts index e2ca3b2..1a16a27 100644 --- a/apps/services/dmp/gateway/src/admin/admin.module.ts +++ b/apps/services/dmp/gateway/src/admin/admin.module.ts @@ -7,11 +7,13 @@ import { ClientsModule, Transport } from '@nestjs/microservices'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/dmp/gateway/src/annotator/annotator.module.ts b/apps/services/dmp/gateway/src/annotator/annotator.module.ts index 833ba4c..d812179 100644 --- a/apps/services/dmp/gateway/src/annotator/annotator.module.ts +++ b/apps/services/dmp/gateway/src/annotator/annotator.module.ts @@ -7,11 +7,13 @@ import { ClientsModule, Transport } from '@nestjs/microservices'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/dmp/gateway/src/app.module.ts b/apps/services/dmp/gateway/src/app.module.ts index e6336d6..0d5a4af 100644 --- a/apps/services/dmp/gateway/src/app.module.ts +++ b/apps/services/dmp/gateway/src/app.module.ts @@ -21,11 +21,13 @@ import * as cookieParser from 'cookie-parser'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/dmp/gateway/src/dicom/dicom.module.ts b/apps/services/dmp/gateway/src/dicom/dicom.module.ts index ad04d74..25ddfc3 100644 --- a/apps/services/dmp/gateway/src/dicom/dicom.module.ts +++ b/apps/services/dmp/gateway/src/dicom/dicom.module.ts @@ -7,11 +7,13 @@ import { ClientsModule, Transport } from '@nestjs/microservices'; ClientsModule.register([ { name: 'Client', - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ]), diff --git a/apps/services/logger/src/main.ts b/apps/services/logger/src/main.ts index 14a0dc7..1f6619d 100644 --- a/apps/services/logger/src/main.ts +++ b/apps/services/logger/src/main.ts @@ -6,11 +6,13 @@ async function bootstrap() { const app = await NestFactory.createMicroservice( AppModule, { - transport: Transport.NATS, + transport: Transport.RMQ, options: { - servers: ['nats://localhost:4222'], // 可以指定链接到多个nats的消息队列 - maxReconnectAttempts: 5, - reconnectTimeWait: 1000, + urls: ['amqp://localhost:5672'], + queue: 'cats_queue', + queueOptions: { + durable: false, + }, }, }, ); diff --git a/docker-compose.rabbit.yml b/docker-compose.rabbit.yml index e731c47..c3f5181 100644 --- a/docker-compose.rabbit.yml +++ b/docker-compose.rabbit.yml @@ -11,6 +11,12 @@ services: environment: - RABBITMQ_DEFAULT_USER=guest - RABBITMQ_DEFAULT_PASS=guest + # volumes: + # - rabbitmq-data:/var/lib/rabbitmq + command: > + bash -c "rabbitmq-plugins enable rabbitmq_management && + rabbitmq-plugins enable rabbitmq_tracing && + rabbitmq-server" mongodb: image: mongo:5.0