统一消息系统

@RequestMapping("/api")

public class NotificationController {

@Autowired

private NotificationService notificationService;

@PostMapping("/send")

public ResponseEntity sendMessage(@RequestBody MessageRequest request) {

notificationService.sendMessage(request);

return ResponseEntity.ok("Message sent successfully");

}

}

const kafka = new Kafka({

clientId: 'message-producer',

brokers: ['localhost:9092']

});

const producer = kafka.producer();

await producer.connect();

await producer.send({

topic: 'notifications',

messages: [

{ value: JSON.stringify({ userId: '123', message: 'Welcome to the system!' }) }

]

});

await producer.disconnect();