异步收集:
js script—request—>后台接口—>异步写文件(id,browser…cookie)—>日志收集(多线程)—>消息中间件(kafka等)—>1.流计算(实时统计) 或 —>2.归档 离线计算—>mysql—>报表
异步处理:
串行:注册—>email—>sms—>入库 (时间长)
并行:注册—>1.email 或 —>2.sms
异步:注册—>MQ(消息中间件)—>1.email 或 2.—>sms
Order--发布—>MQ<—订阅—库存
Request--发布—>MQ<—订阅—业务逻辑
erlang:编写rabbit mq的语言,想要使用rabbit mq必须下载relang
⭐记录一个使用homebrew下载rabbit mq时遇到的问题:
brew update时提示error,解决方法是首先进入到cd /usr/local/Homebrew目录下,执行git pull origin master,之后再执行brew update && brew upgrade即可
获取MQ的连接 java代码:
1.定义一个连接工厂 ConnectionFactory
2.设置服务地址 setHost()
3.使用AMQP协议,设置端口号 setPort()
4.设置虚拟数据库setVirtualHost()
5.设置用户名
6.设置密码
7.获取连接
简单mq:
生产者—>消息中间件—>消费者
生产者发送消息:
1.获取一个链接
2.从连接中获取一个通道
3.声明一个队列
4.定义消息
5.发布消息
6.关闭通道和连接
消费者消费消息:
1.获取一个链接
2.从链接中获取一个通道
3.声明一个队列
4.声明一个默认的消费者 new DefaultConsumer(channel)
重写DefaultConsumer()中的handleDelivery方法,获取body(也就是传递的消息),可以进行log输出监测
5.创建一个基本消费动作,监听队列:channel.basicConsume(queue_name,true,consumer)
简单队列的不足:
耦合性高——生产者一一对应消费者,如果想要多个消费者消费一个队列中的消息,这时候简单队列就不能满足需求
一旦队列名变更,生产者和消费者得同时变更队列名
