1.初步：
?1）消息中間件的作用弊予、RabbitMQ開發(fā)語言翼岁、協(xié)議、啟動命令
?2）生產(chǎn)者代碼基本流程寿桨、消費者代碼基本流程
2.入門
?1）概念：模型框架此衅、生產(chǎn)者(消息組成)强戴、消費者(只消費消息體)、隊列(存儲消息)挡鞍、??????交換機(類型(4+2))
?2）交換機：Exchange.DeclareOk?exchangeDelare(String?exchange,String?type,boolean?durable,boolean?autoDelete,boolean?internal,Map<String,Object>?arguments)
?3）隊列：Queue.?DeclareOk?queueDeclare?(String?queue,?boolean?durable,?boolean?exclusive,boolean?autoDelete,?Map<String,Object>?arguments)?,arguments常用參數(shù)x-message-ttl骑歹、x-expires、x-dead-letter-exchange
?4）發(fā)送消息：void?basicPublish?(String?exchange?,?String?routingKey,?BasicProperties?props?,byte[)?body)墨微，BasicProperties常用參數(shù)contentType道媚、contentEncoding、expiration翘县、Headers最域、DeliveryMode
?5）消息消費模式(推模式Basic.Consume和拉模式Basic.Get)
?6）推模式消費消息：String?basicConsume(String?queue?,?boolean?autoAck,?String?consumerTag,?boolean?noLocal?,?boolean?exclusive,?Map<String,Object>?arguments?,?Consumer?callback)
?7）消息拒絕：void?basicReject(long?deliveryTag,?boolean?requeue)
?????void?basicNack(long?deliveryTag,?boolean?multiple?,?boolean?requeue)?
3.進階
?1）生產(chǎn)者參數(shù)：mandatory和immediate
??a）mandatory：當(dāng)mandatory?參數(shù)設(shè)為true?時，交換器無法根據(jù)自身的類型和路由鍵找到一個符合條件的隊列炼蹦，那么RabbitMQ?會調(diào)用Basic.Return?命令將消息返回給生產(chǎn)者羡宙。當(dāng)mandatory?參數(shù)設(shè)置為false?時，出現(xiàn)上述情形掐隐，則消息直接被丟棄狗热。
??通過調(diào)用channel?.?addReturnListener?來添加ReturnListener?監(jiān)昕器實現(xiàn)
??b）immediate：當(dāng)immediate?參數(shù)設(shè)為true?時，如果交換器在將消息路由到隊列時發(fā)現(xiàn)隊列上并不存在任何消費者虑省，那么這條消息將不會存入隊列中匿刮。當(dāng)與路由鍵匹配的所有隊列都沒有消費者時，該消息會通過Basic?.?Return?返回至生產(chǎn)者探颈。
?2）備份交換機(AE)：alternate-exchange
?3）過期時間TTL：兩種(隊列x-message-ttl毫秒熟丸、消息expiration毫秒，取小)
?4）死信隊列：設(shè)置方式(x-dead-letter-exchange)伪节、消息來源(拒絕光羞、過期、隊列滿)
?5）延遲隊列：通過DLX和TTL模擬實現(xiàn)
?6）持久化：持久化(交換機參數(shù)怀大、隊列參數(shù)纱兑、消息BasicProperties.deliveryMode(2))，RabbitMQ?并不會為每條消息都進行同步存盤(調(diào)用內(nèi)核的fsync方法)的處理化借，可能僅僅保存到操作系統(tǒng)緩存之中而不是物理磁盤之中
?7）生產(chǎn)者消息確認(rèn)：2種方式
??a）事務(wù)機制：channel.txSelect,?channel.txCommit,?channel.txRollback潜慎、確認(rèn)阻塞，降低吞吐量
??b）確認(rèn)機制(publisher?confirm)：channel.confirmSelect蓖康、channel.waitForComfirms铐炫，唯一ID，
???批量確認(rèn)：缺陷重復(fù)批量發(fā)送
???異步確認(rèn)：channel.addConfirmListener中ConfirmListener接口handleAck和handleNack
8）消費者：
??a）消息分發(fā)：多個消費者輪詢
4.RabbitMQ管理
1）多租戶和權(quán)限：?概念
?rabbitmqctl：
??a）add_vhost蒜焊，list_vhost倒信、delete_vhost
??b）set_permissions，clear_permissions泳梆，list_permissions鳖悠，list_user_permissions
2）用戶管理：
??rabbitmqctl：
??add_user唆迁、change_password、authenticate_user竞穷、delete_user、list_users鳞溉、set_user_tags
5.RabbitMQ集群
?1）基礎(chǔ)：RabbitMQ集群只適合本地局域網(wǎng)使用瘾带，所有節(jié)點只備份所有元數(shù)組信息(交換機、隊列熟菲、綁定看政、vhost)、不會備份消息抄罕，節(jié)點類型分為內(nèi)存(ram)和硬盤(disc)
?2）配置步驟：
??a）配置hosts允蚣，復(fù)制cookie
??b）啟動服務(wù)，加入節(jié)點呆贿，rabbitmqctl?join_cluster?rabbit@node1?--disc
???其他命令：rabbitmqctl?cluster_status嚷兔、rabbitmqctl?stop_app、rabbitmqctl?reset做入、rabbitmqctl?start_app
?3）注意事項
??a）關(guān)閉所有節(jié)點后冒晰，確保首先啟動最后關(guān)閉節(jié)點
??b）剔除節(jié)點?rabbitmqctl?forget_cluster_node，所有節(jié)點斷電等啟動rabbitmqctl?force_boot
??c）集群擴容竟块，既有元數(shù)組信息不會自動遷移壶运，通過UI導(dǎo)出導(dǎo)入
