三、登录进入MQ

Publisher是消息的发送者负责将消息发送到交换机交换机负责路由将消息暂存到消息队列队列负责暂存消息消费者从队列获取消息然后处理消息每个虚拟主机相互之间是隐藏的避免干扰

channel:操作MQ的工具exchange:路由消息到队列中queue:缓存消息virtual

host:虚拟主机是对queue、exchange等资源的逻辑分组

五、常见消息模型

java.util.concurrent.TimeoutException;public

class

1.1.设置连接参数分别是主机名、端口号、vhost、用户名、密码factory.setHost(192.168.248.152);factory.setPort(5672);factory.setVirtualHost(/);factory.setUsername(itcast);factory.setPassword(123456);//

1.2.建立连接Connection

simple.queue;channel.queueDeclare(queueName,

false,

4.订阅消息channel.basicConsume(queueName,

true,

DefaultConsumer(channel){Overridepublic

void

String(body);System.out.println(接收到消息【

message

】);}});System.out.println(等待接收消息。

。

。

。

);}

}2、生产者类

java.util.concurrent.TimeoutException;public

class

1.1.设置连接参数分别是主机名、端口号、vhost、用户名、密码factory.setHost(192.168.248.152);factory.setPort(5672);factory.setVirtualHost(/);factory.setUsername(itcast);factory.setPassword(123456);//

1.2.建立连接Connection

simple.queue;channel.queueDeclare(queueName,

false,

4.订阅消息channel.basicConsume(queueName,

true,

DefaultConsumer(channel){Overridepublic

void

String(body);System.out.println(接收到消息【

message

】);}});System.out.println(等待接收消息。

。

。

。

);}

建立connection创建channel利用channel声明队列利用channel向队列发送消息

建立connection创建channel利用channel声明队列定义consumer的消费行为handleDelivery()利用channel将消费者与队列绑定