\u8bd1\u8005 | \u674e\u777f<\/p>\n
\u5ba1\u6821 | \u5b59\u6dd1\u5a1f<\/p>\n
\u4e3a\u4e86\u8bf4\u660e\u5982\u4f55\u4f7f\u7528Kubernetes\uff0c\u5efa\u8bae\u8003\u8651\u672c\u6587\u4ecb\u7ecd\u7684\u533a\u5757\u94fe\u6848\u4f8b\uff0c\u5e76\u63a2\u8ba8\u4e3a\u52a0\u5bc6\u8d27\u5e01\u5e02\u573a\u5f00\u53d1\u7684\u5e94\u7528\u7a0b\u5e8f\u3002\u8fd9\u4e2a\u5e94\u7528\u7a0b\u5e8f\u4f7f\u7528\u7684\u6280\u672f\u662f\u5b9e\u7528\u7684\uff0c\u4e5f\u53ef\u4ee5\u7528\u4e8e\u5176\u4ed6\u9879\u76ee\u3002\u6362\u53e5\u8bdd\u8bf4\uff0c\u6280\u672f\u4efb\u52a1\u662f\u4e00\u4e2a\u975e\u5e38\u901a\u7528\u7684\u89e3\u51b3\u65b9\u6848\uff0c\u4e3b\u8981\u9488\u5bf9Kubernetes\u8fdb\u884c\u4e86\u4e13\u95e8\u8c03\u6574\uff0c\u4e5f\u53ef\u4ee5\u7528\u4e8e\u5176\u4ed6\u884c\u4e1a\u3002<\/p>\n
\u8be5\u9879\u76ee\u662f\u4e00\u4e2a\u542f\u52a8\u9879\u76ee\uff0c\u9884\u7b97\u6709\u9650\u3002\u800c\u5f00\u53d1\u4eba\u5458\u5c06\u5b9a\u671f\u4e3a\u6295\u8d44\u8005\u63d0\u4f9b\u6f14\u793a\uff0c\u5e76\u5b9a\u671f\u5c55\u793a\u5f00\u53d1\u65b0\u529f\u80fd\u7684\u8fdb\u5c55\u60c5\u51b5\u3002\u56e0\u6b64\u51b3\u5b9a\u4f7f\u7528\u4ee5\u4e0b\u6280\u672f\uff1a<\/p>\n
\u5bf9\u4e8e\u7b2c\u4e00\u9636\u6bb5\uff0c\u5f00\u53d1\u4eba\u5458\u7684\u4e3b\u8981\u76ee\u7684\u662f\u5c06\u5176\u5e94\u7528\u7a0b\u5e8f\u62c6\u5206\u4e3a\u5fae\u670d\u52a1\u3002\u5728\u8fd9\u4e00\u6848\u4f8b\u4e2d\uff0c\u51b3\u5b9a\u521b\u5efa6\u4e2a\u5fae\u670d\u52a1\u3002<\/p>\n
(1)\u7ba1\u7406\u5fae\u670d\u52a1<\/p>\n
(2)\u6838\u5fc3\u5fae\u670d\u52a1<\/p>\n
(3)\u652f\u4ed8\u5fae\u670d\u52a1<\/p>\n
(4)\u90ae\u4ef6\u548c\u901a\u77e5\u670d\u52a1<\/p>\n
(5)Cron\u4efb\u52a1\u670d\u52a1<\/p>\n
(6)Webhooks\u5fae\u670d\u52a1<\/p>\n
\u503c\u5f97\u4e00\u63d0\u7684\u662f\uff0c\u867d\u7136\u6280\u672f\u5806\u6808\u662f\u5b9e\u7528\u7684\uff0c\u5e76\u4e14\u53ef\u4ee5\u5728\u5404\u79cd\u60c5\u51b5\u4e0b\u4f7f\u7528\u800c\u65e0\u9700\u66f4\u6539\uff0c\u4f46\u4e0a\u8ff0\u5fae\u670d\u52a1\u5374\u4e0d\u662f\uff0c\u5b83\u4eec\u662f\u4e13\u95e8\u4e3a\u8fd9\u4e00\u9879\u76ee\u4e2d\u6240\u9700\u7684\u529f\u80fd\u800c\u521b\u5efa\u7684\u3002\u56e0\u6b64\u53ef\u4ee5\u4f7f\u7528\u76f8\u540c\u7684\u6280\u672f\uff0c\u4f46\u5fc5\u987b\u6839\u636e\u9700\u8981\u8bbe\u8ba1\u65b0\u7684\u5fae\u670d\u52a1\u3002<\/p>\n
\u4ee5\u4e0b\u4e86\u89e3\u5982\u4f55\u5728NestJS\u4e0a\u5236\u4f5c\u8fd9\u4e9b\u5fae\u670d\u52a1\u3002\u9700\u8981\u4e3aKafka\u6d88\u606f\u4ee3\u7406\u8fdb\u884c\u914d\u7f6e\u9009\u9879\u3002\u56e0\u6b64\uff0c\u4e3a\u6240\u6709\u5fae\u670d\u52a1\u7684\u5e38\u7528\u6a21\u5757\u548c\u914d\u7f6e\u521b\u5efa\u4e86\u4e00\u4e2a\u5171\u4eab\u8d44\u6e90\u6587\u4ef6\u5939\u3002<\/p>\n
import<\/span> { ClientProviderOptions<\/span>, Transport<\/span> } from<\/span> '@nestjs\/microservices'<\/span>;
import<\/span> CONFIG<\/span> from<\/span> '@application-config'<\/span>;
import<\/span> { ConsumerGroups<\/span>, ProjectMicroservices<\/span> } from<\/span> '.\/microservices.enum'<\/span>;
const<\/span> { BROKER_HOST<\/span>, BROKER_PORT<\/span> } =<\/span> CONFIG<\/span>.KAFKA<\/span>;
export<\/span> const<\/span> PRODUCER_CONFIG<\/span> =<\/span> (name<\/span>: ProjectMicroservices<\/span>): ClientProviderOptions<\/span> =><\/span> ({
name<\/span>,
transport<\/span>: Transport<\/span>.KAFKA<\/span>,
options<\/span>: {
client<\/span>: {
brokers<\/span>: [`${<\/span>BROKER_HOST<\/span>}<\/span>:${<\/span>BROKER_PORT<\/span>}<\/span>`<\/span>],
},
}
});
export<\/span> const<\/span> CONSUMER_CONFIG<\/span> =<\/span> (groupId<\/span>: ConsumerGroups<\/span>) =><\/span> ({
transport<\/span>: Transport<\/span>.KAFKA<\/span>,
options<\/span>: {
client<\/span>: {
brokers<\/span>: [`${<\/span>BROKER_HOST<\/span>}<\/span>:${<\/span>BROKER_PORT<\/span>}<\/span>`<\/span>],
},
consumer<\/span>: {
groupId<\/span>
}
}
});<\/pre>\n\u4ee5\u6d88\u8d39\u8005\u6a21\u5f0f\u5c06\u7ba1\u7406\u9762\u677f\u5fae\u670d\u52a1\u8fde\u63a5\u5230Kafka\u3002\u5b83\u5c06\u5141\u8bb8\u6355\u83b7\u548c\u5904\u7406\u6765\u81ea\u4e3b\u9898\u7684\u4e8b\u4ef6\u3002<\/p>\n
\u4f7f\u5e94\u7528\u7a0b\u5e8f\u5728\u5fae\u670d\u52a1\u6a21\u5f0f\u4e0b\u5de5\u4f5c\uff0c\u4ee5\u4fbf\u80fd\u591f\u4f7f\u7528\u4e8b\u4ef6\uff1a<\/p>\n
app<\/span>.connectMicroservice<\/span>(CONSUMER_CONFIG<\/span>(ConsumerGroups<\/span>.ADMIN<\/span>)); await<\/span> app<\/span>.startAllMicroservices<\/span>();<\/pre>\n\u53ef\u4ee5\u6ce8\u610f\u5230\u6d88\u8d39\u8005\u914d\u7f6e\u5305\u542bgroupId\u3002\u8fd9\u662f\u4e00\u4e2a\u91cd\u8981\u7684\u9009\u9879\uff0c\u5b83\u5c06\u5141\u8bb8\u6765\u81ea\u540c\u4e00\u7ec4\u7684\u6d88\u8d39\u8005\u4ece\u4e3b\u9898\u4e2d\u83b7\u53d6\u4e8b\u4ef6\uff0c\u5e76\u5c06\u5b83\u4eec\u5206\u53d1\u7ed9\u5f7c\u6b64\u4ee5\u66f4\u5feb\u5730\u5904\u7406\u5b83\u4eec\u3002<\/p>\n
\u4f8b\u5982\uff0c\u5047\u8bbe\u5fae\u670d\u52a1\u63a5\u6536\u4e8b\u4ef6\u7684\u901f\u5ea6\u5feb\u4e8e\u5904\u7406\u5b83\u4eec\u7684\u901f\u5ea6\u3002\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0c\u53ef\u4ee5\u8fdb\u884c\u81ea\u52a8\u6269\u5c55\u4ee5\u751f\u6210\u989d\u5916\u7684pod\u4ee5\u5728\u5b83\u4eec\u4e4b\u95f4\u5171\u4eab\u8d1f\u8f7d\uff0c\u5e76\u4f7f\u8be5\u8fc7\u7a0b\u52a0\u5feb\u4e24\u500d\u3002<\/p>\n
\u4e3a\u4e86\u5b9e\u73b0\u8fd9\u4e00\u70b9\uff0c\u6d88\u8d39\u8005\u5e94\u8be5\u5728\u7ec4\u4e2d\uff0c\u5e76\u4e14\u5728\u6269\u5c55\u4e4b\u540e\uff0c\u751f\u6210\u7684pod\u4e5f\u5c06\u5728\u540c\u4e00\u4e2a\u7ec4\u4e2d\u3002\u56e0\u6b64\uff0c\u4ed6\u4eec\u5c06\u80fd\u591f\u5171\u4eab\u52a0\u8f7d\uff0c\u800c\u4e0d\u662f\u5904\u7406\u6765\u81ea\u4e0d\u540cKafka\u5206\u533a\u7684\u76f8\u540c\u4e3b\u9898\u4e8b\u4ef6\u3002<\/p>\n
\u4ee5\u4e0b\u4e86\u89e3\u4e00\u4e2a\u5982\u4f55\u5728NestJS\u4e2d\u6355\u83b7\u548c\u5904\u7406Kafka\u4e8b\u4ef6\u7684\u793a\u4f8b\uff1a<\/p>\n
\u6d88\u8d39\u8005\u63a7\u5236\u5668<\/h4>\nimport<\/span> { Controller<\/span> } from<\/span> '@nestjs\/common'<\/span>;
import<\/span> { Ctx<\/span>, KafkaContext<\/span>, MessagePattern<\/span>, EventPattern<\/span>, Payload<\/span> } from<\/span> '@nestjs\/microservices'<\/span>;
@<\/span>Controller<\/span>('consumer'<\/span>)
export<\/span> class<\/span> ConsumerController<\/span> {
@<\/span>MessagePattern<\/span>('hero'<\/span>)
readMessage<\/span>(@<\/span>Payload<\/span>() message<\/span>: any<\/span>, @<\/span>Ctx<\/span>() context<\/span>: KafkaContext<\/span>) {
return<\/span> message<\/span>;
}
@<\/span>EventPattern<\/span>('event-hero'<\/span>)
sendNotif<\/span>(data<\/span>) {
console<\/span>.log<\/span>(data<\/span>);
}
}<\/pre>\n\u6d88\u8d39\u8005\u53ef\u4ee5\u5728\u4e24\u79cd\u6a21\u5f0f\u4e0b\u5de5\u4f5c\u3002\u5b83\u63a5\u6536\u4e8b\u4ef6\u5e76\u5904\u7406\u5b83\u4eec\u800c\u4e0d\u8fd4\u56de\u4efb\u4f55\u54cd\u5e94(EventPattern decorator)\uff0c\u6216\u8005\u5728\u5904\u7406\u4e8b\u4ef6\u540e\u5c06\u54cd\u5e94\u8fd4\u56de\u7ed9\u751f\u4ea7\u8005(MessagePattern decorator)\u3002EventPattern\u66f4\u597d\uff0c\u5982\u679c\u53ef\u80fd\u7684\u8bdd\u5e94\u8be5\u662f\u9996\u9009\uff0c\u56e0\u4e3a\u5b83\u4e0d\u5305\u542b\u4efb\u4f55\u989d\u5916\u7684\u6e90\u4ee3\u7801\u5c42\u6765\u63d0\u4f9b\u8bf7\u6c42\/\u54cd\u5e94\u529f\u80fd\u3002<\/p>\n
\u751f\u4ea7\u8005\u5462?<\/h4>\n
\u5bf9\u4e8e\u8fde\u63a5\u751f\u4ea7\u8005\uff0c\u9700\u8981\u4e3a\u8d1f\u8d23\u53d1\u9001\u4e8b\u4ef6\u7684\u6a21\u5757\u63d0\u4f9b\u751f\u4ea7\u8005\u914d\u7f6e\u3002<\/p>\n
\u751f\u4ea7\u8005\u8fde\u63a5<\/h4>\nimport<\/span> { Module<\/span> } from<\/span> '@nestjs\/common'<\/span>;
import<\/span> DatabaseModule<\/span> from<\/span> '@shared\/database\/database.module'<\/span>;
import<\/span> { ClientsModule<\/span> } from<\/span> '@nestjs\/microservices'<\/span>;
import<\/span> { ProducerController<\/span> } from<\/span> '.\/producer.controller'<\/span>;
import<\/span> { PRODUCER_CONFIG<\/span> } from<\/span> '@shared\/microservices\/microservices.config'<\/span>;
import<\/span> { ProjectMicroservices<\/span> } from<\/span> '@shared\/microservices\/microservices.enum'<\/span>;
@<\/span>Module<\/span>({
imports<\/span>: [
DatabaseModule<\/span>,
ClientsModule<\/span>.register<\/span>([PRODUCER_CONFIG<\/span>(ProjectMicroservices<\/span>.ADMIN<\/span>)]),
],
controllers<\/span>: [ProducerController<\/span>],
providers<\/span>: [],
})
export<\/span> class<\/span> ProducerModule<\/span> {}<\/pre>\n\u57fa\u4e8e\u4e8b\u4ef6\u7684\u751f\u4ea7\u8005<\/h4>\nimport<\/span> { Controller<\/span>, Get<\/span>, Inject<\/span> } from<\/span> '@nestjs\/common'<\/span>;
import<\/span> { ClientKafka<\/span> } from<\/span> '@nestjs\/microservices'<\/span>;
import<\/span> { ProjectMicroservices<\/span> } from<\/span> '@shared\/microservices\/microservices.enum'<\/span>;
@<\/span>Controller<\/span>('producer'<\/span>)
export<\/span> class<\/span> ProducerController<\/span> {
constructor<\/span>(
@<\/span>Inject<\/span>(ProjectMicroservices<\/span>.ADMIN<\/span>)
private<\/span> readonly<\/span> client<\/span>: ClientKafka<\/span>,
) {}
@<\/span>Get<\/span>()
async<\/span> getHello<\/span>() {
this<\/span>.client<\/span>.emit<\/span>('event-hero'<\/span>, { msg<\/span>: 'Event Based'<\/span>});
}
}<\/pre>\n\u57fa\u4e8e\u8bf7\u6c42\/\u54cd\u5e94\u7684\u751f\u4ea7\u8005<\/h4>\nimport<\/span> { Controller<\/span>, Get<\/span>, Inject<\/span> } from<\/span> '@nestjs\/common'<\/span>;
import<\/span> { ClientKafka<\/span> } from<\/span> '@nestjs\/microservices'<\/span>;
import<\/span> { ProjectMicroservices<\/span> } from<\/span> '@shared\/microservices\/microservices.enum'<\/span>;
@<\/span>Controller<\/span>('producer'<\/span>)
export<\/span> class<\/span> ProducerController<\/span> {
constructor<\/span>(
@<\/span>Inject<\/span>(ProjectMicroservices<\/span>.ADMIN<\/span>)
private<\/span> readonly<\/span> client<\/span>: ClientKafka<\/span>,
) {}
async<\/span> onModuleInit<\/span>() {
\/\/ Need to subscribe to a topic<\/span>
\/\/ to make the response receiving from Kafka microservice possible<\/span>
this<\/span>.client<\/span>.subscribeToResponseOf<\/span>('hero'<\/span>);
await<\/span> this<\/span>.client<\/span>.connect<\/span>();
}
@<\/span>Get<\/span>()
async<\/span> getHello<\/span>() {
const<\/span> responseBased<\/span> =<\/span> this<\/span>.client<\/span>.send<\/span>(