typescript 连接rabbitmq

TypeScript 是 JavaScript 的一个超集，添加了静态类型定义的功能。由于 TypeScript 最终会被编译成 JavaScript，因此你可以在 TypeScript 中使用任何在 JavaScript 中可用的库或工具。连接 RabbitMQ 的过程与在 JavaScript 中的连接过程类似，但你可能会使用 TypeScript 的类型定义来提高代码的健壮性。

首先，你需要一个用于连接 RabbitMQ 的客户端库，比如 `amqplib`。你可以在 TypeScript 项目中通过 npm 或 yarn 安装这个库：

npm install amqplib

或者

yarn add amqplib

然后，在 TypeScript 文件中，你可以使用 `import` 语句来引入这个库，并且利用 TypeScript 的类型定义来编写代码：

import * as amqp from 'amqplib';

async function connectToRabbitMQ(url: string) {
    const connection = await amqp.connect(url);
    console.log('RabbitMQ 连接成功');

    const channel = await connection.createChannel();
    await channel.assertQueue('test', { durable: false });
    console.log('队列声明成功');

    // 发送消息示例
    channel.sendToQueue('test', Buffer.from('Hello World!'));

    // 获取消息示例
    channel.consume('test', message => {
        console.log('接收到消息:', message.content.toString());
        channel.ack(message);
    }, { noAck: false });
}

connectToRabbitMQ('amqp://localhost');

在这个例子中，`connectToRabbitMQ` 函数接受一个 RabbitMQ 服务的连接 URL，然后使用这个 URL 连接到 RabbitMQ。之后，它创建一个信道、声明一个队列，并向队列发送一条消息。最后，它设置了对同一个队列的消费，打印接收到的消息。

要注意的是，RabbitMQ 的连接 URL 通常遵循 `amqp://username:password@hostname:port/vhost` 的格式。你可能需要根据你的 RabbitMQ 服务器的实际设置来修改这个 URL。