>[info] fanout 訂閱/廣播模式
交換器會把所有發送到該交換器的消息路由到所有與該交換器綁定的消息隊列中。**訂閱模式與Binding Key和Routing Key無關**,交換器將接受到的消息分發給有綁定關系的所有消息隊列隊列(不論Binding Key和Routing Key是什么)。類似于子網**廣播**,子網內的每臺主機都獲得了一份復制的消息。**Fanout交換機轉發消息是最快的**。


1. `rabbitmq.php` 配置文件信息
~~~
<?php
// rabbitmq 配置信息
return [
# 連接信息
'amqp' => [
'host' => '127.0.0.1',
'port'=>'5672',
'user'=>'guest',
'password'=>'guest',
'vhost'=>'/'
],
# 扇出隊列
'fanout_queue' => [
'exchange_name' => 'fanout_exchange',
'exchange_type'=>'fanout',# 訂閱/廣播模式
'queue_name' => 'fanout_queue',
'route_key' => 'fanout_route_key',
'consumer_tag' => 'fanout'
],
# 商品隊列
'goods_queue' => [
'exchange_name' => 'goods_fanout_exchange',
'exchange_type'=>'fanout',# 訂閱/廣播模式
'queue_name' => 'goods_queue',
'route_key' => 'goods_route_key',
'consumer_tag' => 'goods'
],
# 訂單隊列
'order_queue' => [
'exchange_name' => 'order_fanout_exchange',
'exchange_type'=>'fanout',# 訂閱/廣播模式
'queue_name' => 'order_queue',
'route_key' => 'order_route_key',
'consumer_tag' => 'order'
],
];
~~~
2. `Consumer` 消費者
~~~
<?php
declare (strict_types = 1);
namespace app\common\service\rabbitmq;
//use app\common\model\test\MessageModel;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use think\facade\Log;
/**
* 消費者
*/
class Consumer
{
/**
* 商品消費者
* @return \think\Response
*/
public function goods()
{
$mqConfig = config('rabbitmq.amqp');
$goodsConfig = config('rabbitmq.goods_queue');
// 創建連接
$connection = new AMQPStreamConnection(
$mqConfig['host'],
$mqConfig['port'],
$mqConfig['user'],
$mqConfig['password'],
$mqConfig['vhost']
);
// 連接信道
$channel = $connection->channel();
// 設置消費者(Consumer)客戶端同時只處理一條隊列
// 這樣是告訴RabbitMQ,再同一時刻,不要發送超過1條消息給一個消費者(Consumer),
// 直到它已經處理了上一條消息并且作出了響應。這樣,RabbitMQ就會把消息分發給下一個空閑的消費者(Consumer)。
// 消費者端要把自動確認autoAck設置為false,basic_qos才有效。
// 流量控制
$channel->basic_qos(0, 1, false);
// 同樣是創建路由和隊列,以及綁定路由隊列,注意要跟producer(生產者)的一致
// 這里其實可以不用設置,但是為了防止隊列沒有被創建所以做的容錯處理
// 創建交換機(Exchange)
$channel->exchange_declare($goodsConfig['exchange_name'], $goodsConfig['exchange_type'], false, true, false);
// 創建隊列
$channel->queue_declare($goodsConfig['queue_name'], false, true, false, false);
// 綁定隊列和交換機
$channel->queue_bind($goodsConfig['queue_name'], $goodsConfig['exchange_name']);
/**
* 消費消息
*
* queue: queue_name 被消費的隊列名稱
* consumer_tag: consumer_tag 消費者客戶端身份標識,用于區分多個客戶端
* no_local: false 這個功能屬于AMQP的標準,但是RabbitMQ并沒有做實現
* no_ack: true 收到消息后,是否不需要回復確認即被認為被消費
* exclusive: false 是否排他,即這個隊列只能由一個消費者消費。適用于任務不允許進行并發處理的情況下
* nowait: false 不返回執行結果,但是如果排他開啟的話,則必須需要等待結果的,如果兩個一起開就會報錯
* callback: $callback 回調邏輯處理函數
*/
$channel->basic_consume($goodsConfig['queue_name'], $goodsConfig['consumer_tag'], false, false, false, false, array($this, 'process_message'));
// 退出,執行shutdown來關閉通道與連接
register_shutdown_function(array($this, 'shutdown'), $channel, $connection);
// 阻塞隊列監聽事件
while (count($channel->callbacks)) {
$channel->wait();
}
}
/**
* 訂單消費者
* @return \think\Response
*/
public function order()
{
$mqConfig = config('rabbitmq.amqp');
$orderConfig = config('rabbitmq.order_queue');
// 創建連接
$connection = new AMQPStreamConnection(
$mqConfig['host'],
$mqConfig['port'],
$mqConfig['user'],
$mqConfig['password'],
$mqConfig['vhost']
);
// 連接信道
$channel = $connection->channel();
// 設置消費者(Consumer)客戶端同時只處理一條隊列
// 這樣是告訴RabbitMQ,再同一時刻,不要發送超過1條消息給一個消費者(Consumer),
// 直到它已經處理了上一條消息并且作出了響應。這樣,RabbitMQ就會把消息分發給下一個空閑的消費者(Consumer)。
// 消費者端要把自動確認autoAck設置為false,basic_qos才有效。
// 流量控制
$channel->basic_qos(0, 1, false);
// 同樣是創建路由和隊列,以及綁定路由隊列,注意要跟producer(生產者)的一致
// 這里其實可以不用設置,但是為了防止隊列沒有被創建所以做的容錯處理
// 創建交換機(Exchange)
$channel->exchange_declare($orderConfig['exchange_name'], $orderConfig['exchange_type'], false, true, false);
// 創建隊列
$channel->queue_declare($orderConfig['queue_name'], false, true, false, false);
// 綁定隊列和交換機
$channel->queue_bind($orderConfig['queue_name'], $orderConfig['exchange_name']);
/**
* 消費消息
*
* queue: queue_name 被消費的隊列名稱
* consumer_tag: consumer_tag 消費者客戶端身份標識,用于區分多個客戶端
* no_local: false 這個功能屬于AMQP的標準,但是RabbitMQ并沒有做實現
* no_ack: true 收到消息后,是否不需要回復確認即被認為被消費
* exclusive: false 是否排他,即這個隊列只能由一個消費者消費。適用于任務不允許進行并發處理的情況下
* nowait: false 不返回執行結果,但是如果排他開啟的話,則必須需要等待結果的,如果兩個一起開就會報錯
* callback: $callback 回調邏輯處理函數
*/
$channel->basic_consume($orderConfig['queue_name'], $orderConfig['consumer_tag'], false, false, false, false, array($this, 'process_message'));
// 退出,執行shutdown來關閉通道與連接
register_shutdown_function(array($this, 'shutdown'), $channel, $connection);
// 阻塞隊列監聽事件
while (count($channel->callbacks)) {
$channel->wait();
}
}
/**
* 消息處理
* @param $message
*/
public function process_message($message)
{
if ($message->body !== 'quit') {
$messageBody = json_decode($message->body);
// 自定義的消息類型
if (!isset($messageBody->message_type)) {
Log::write("error data:" . $message->body, 2);
} else {
// $messageModel = new MessageModel();
try {
// 消息
Log::write("message_data:" . json_encode($message, JSON_UNESCAPED_UNICODE));
$body = json_decode($message->body, true);
dump("消費消息如下:");
dump($body);
// $messageModel->test($body);
} catch (\Think\Exception $e) {
Log::write($e->getMessage(), 2);
Log::write(json_encode($message), 2);
} catch (\PDOException $pe) {
Log::write($pe->getMessage(), 2);
Log::write(json_encode($message), 2);
}
}
}
// 手動確認ack,確保消息已經處理
$message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
// Send a message with the string "quit" to cancel the consumer.
if ($message->body === 'quit') {
$message->delivery_info['channel']->basic_cancel($message->delivery_info['consumer_tag']);
}
}
/**
* 關閉進程
* @param $channel
* @param $connection
*/
public function shutdown($channel, $connection)
{
// 關閉信道
$channel->close();
// 關閉連接
$connection->close();
}
}
~~~
3. `Producer` 生產者
~~~
<?php
declare (strict_types = 1);
namespace app\common\service\rabbitmq;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
/**
* rabbitmq 生產者
*/
class Producer
{
// 連接
protected $connection;
// 管道
protected $channel;
// 配置內容(基本)
protected $mqConfig;
// 配置內容(扇出)
protected $fanoutConfig;
public function __construct()
{
$this->mqConfig = config('rabbitmq.amqp');
$this->fanoutConfig = config('rabbitmq.fanout_queue');
// 創建連接
$this->connection = new AMQPStreamConnection(
$this->mqConfig['host'],
$this->mqConfig['port'],
$this->mqConfig['user'],
$this->mqConfig['password'],
$this->mqConfig['vhost'] // 虛擬主機(起到消息隔離的作用)
);
// 創建通道
$this->channel = $this->connection->channel();
}
/**
* 發送消息
* @param $data 消息內容
*/
public function send($data)
{
/*
* 流量控制 Specifies QoS
* 消費者在開啟acknowledge的情況下,對接收到的消息需要異步對消息進行確認
* 由于消費者自身處理能力有限,從rabbitmq獲取一定數量的消息后,希望rabbitmq不再將隊列中的消息推送過來,
* 當對消息處理完后(即對消息進行了ack,并且有能力處理更多的消息)再接收來自隊列的消息
* @param int $prefetch_size 最大unacked消息的字節數
* @param int $prefetch_count 最大unacked消息的條數
* @param bool $a_global 上述限制的限定對象,false限制單個消費者,true限制整個通道
* @return mixed
*/
$this->channel->basic_qos(0, 1, false);
/**
* 創建隊列(Queue)
* name: hello 隊列名稱
* passive: false 如果設置true存在則返回OK,否則就報錯。設置false存在返回OK,不存在則自動創建
* durable: true 是否持久化,設置false是存放到內存中的,RabbitMQ重啟后會丟失;設置true,則代表是一個持久化的隊列,服務重啟后也會存在,因為服務會把持久化的queue存放到磁盤上當服務重啟的時候,會重新加載之前被持久化的queue
* exclusive: false 是否排他,指定該選項為true則隊列只對當前連接有效,連接斷開后自動刪除
* auto_delete: false 是否自動刪除,當最后一個消費者斷開連接之后隊列是否自動被刪除
*/
$this->channel->queue_declare($this->fanoutConfig['queue_name'], false, true, false, false);
/**
* 創建交換機(Exchange)
* name: hello 交換機名稱
* type: direct 交換機類型,分別為direct/fanout/topic,參考另外文章的Exchange Type說明。
* passive: false 如果設置true存在則返回OK,否則就報錯。設置false存在返回OK,不存在則自動創建
* durable: false 是否持久化,設置false是存放到內存中的,RabbitMQ重啟后會丟失
* auto_delete: false 是否自動刪除,當最后一個消費者斷開連接之后隊列是否自動被刪除
*/
$this->channel->exchange_declare($this->fanoutConfig['exchange_name'], $this->fanoutConfig['exchange_type'], false, true, false);
// 綁定消息交換機和隊列
$this->channel->queue_bind($this->fanoutConfig['queue_name'], $this->fanoutConfig['exchange_name'],$this->fanoutConfig['route_key']);
// 將要發送數據變為json字符串
$messageBody = json_encode($data, JSON_UNESCAPED_UNICODE);
/**
* 創建AMQP消息類型
* delivery_mode 消息是否持久化
* AMQPMessage::DELIVERY_MODE_NON_PERSISTENT 不持久化
* AMQPMessage::DELIVERY_MODE_PERSISTENT 持久化
*/
$message = new AMQPMessage($messageBody, [
'content_type' => 'text/plain',
'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT
]);
/**
* 發送消息
* msg: $message AMQP消息內容
* exchange: vckai_exchange 交換機名稱
* routing_key: hello 路由key
*/
$this->channel->basic_publish($message, $this->fanoutConfig['exchange_name'], $this->fanoutConfig['route_key']);
// 關閉連接
$this->stop();
}
// 關閉連接
public function stop()
{
$this->channel->close();
$this->connection->close();
}
}
~~~
4. 創建 `goods` 和 `order` 自定義命令,作為消費者。
~~~php
php think make:command Goods
~~~
~~~
<?php
declare (strict_types = 1);
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use app\common\service\rabbitmq\Consumer;
class Goods extends Command
{
protected function configure()
{
// 指令配置
$this->setName('goods')
->setDescription('the goods command');
}
protected function execute(Input $input, Output $output)
{
// 啟動消費者
$consumer = new Consumer();
$consumer->goods();
}
}
~~~
```
php think make:command Order
```
~~~
<?php
declare (strict_types = 1);
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use app\common\service\rabbitmq\Consumer;
class Order extends Command
{
protected function configure()
{
// 指令配置
$this->setName('order')
->setDescription('the order command');
}
protected function execute(Input $input, Output $output)
{
// 啟動消費者
$consumer = new Consumer();
$consumer->order();
}
}
~~~
5. 配置 `config/console.php` 命令行
~~~
<?php
// +----------------------------------------------------------------------
// | 控制臺配置
// +----------------------------------------------------------------------
return [
// 指令定義
'commands' => [
// rabbitMq 調用消費者
'consumer' => 'app\command\Consumer',
// 商品
'goods' => 'app\command\Goods',
// 訂單
'order' => 'app\command\Order',
],
];
~~~
6. 路由發送消息 `route/app.php`
~~~
Route::get('rabbitmq', function (){
$producer = new \app\common\service\rabbitmq\Producer();
$data = [
'message_type' => 2,
'order_id' => 3,
'user_id' => 3,
'time' => time(),
'message' => "發送的消息內容:您的快遞已到的配送站。(" . rand(1,100) . ")"
];
$producer->send($data);
});
~~~
7. 啟動消費者
```
php think order
```
```
php think goods
```
8. 生產者發送消息



- PHP
- ThinkPHP5
- 變量修飾符:input()
- 常用函數封裝
- 01. 數據集轉為樹(Tree)
- 02. 生成訂單號
- 03. 將時間戳轉換為日期時間
- 04. 將字節轉換為可讀文本
- 05. 首字母頭像
- 06. 隨機小數/截取小數
- 07. 判斷字符串是否序列化
- 08. 根據生日計算年齡
- 09. 判斷是PC或WAP端
- 10. 請求網頁返回code碼狀態
- 11. 計算代碼執行時間
- 12. String 字符處理類
- 13. Http 請求類
- 14. StrRand 隨機生成字符類
- 15. 獲取當天開始時間和結束時間
- 16. 手機郵箱身份證
- 17. jsonEncode和jsonDecode助手函數
- 18. tp6跨域檢測
- 19.日期轉換為時間戳
- 20.excel導入日期格式問題
- 21.取整數函數常用的四種方法
- 22.PHPExcel導入導出
- 23.計算文件大小
- 24.計算按天數
- 25.文件夾不存在則創建
- 26.遞歸獲取部門所有子級id
- 27.根據用戶名生成默認文字頭像
- 28.生成短信驗證碼
- 29.數據脫敏
- 30.根據身份證判斷禁止未成年人下單
- 31.數組向指定位置插入元素
- 32.從字符串中獲取城市名稱
- 33.收貨地址拆分省市區
- 34.根據時間戳獲取本月開始-結束日期
- 35.循環每次查詢指定數據集
- 36.判斷日期是否符合范圍
- Laravel6
- 01.Dingo API 2.0.0 擴展包
- 01.laravel 安裝擴展包
- 02.創建端點
- 03.響應
- 04.api認證
- 監聽sql 語句
- 安裝easywechat
- 路由分組
- ThinkPHP6
- ThinkPHP6讀寫分離
- 定時計劃任務
- 偽靜態
- 多應用模式
- Join關聯查詢
- 跨域中間件
- extend擴展
- 1.操縱文件類
- 2.壓縮包驅動
- Xdebug調試
- Easy Task開發文檔
- 01.EasyTask介紹
- 02.EasyTask環境安裝
- 03.EasyTask基礎入門
- EasySwoole
- 999.狀態類
- 01.EasySwoole快速開始
- 1.EasySwoole介紹
- 2.EasySwoole快速上手
- 3.EasySwoole基本管理命令
- 4.EasySwoole基礎開始示例(CURD)
- 02.EasySwoole協程操作指南
- 1.什么是協程
- MySQL
- MySQL批量修改表前綴
- 重置【主鍵ID】
- 查看【文件存儲位置】
- MySQL主從同步
- 添加用戶權限
- MySQL主從復制集群
- 01.主從復制技術原理介紹
- 02.基于 binlog 主從復制搭建
- 03.基于binlog不影響業務搭建主從
- 04.主從復制 binlog 格式
- 05.主從復制過濾規則
- 06.在線增加從服務器
- 07.MySQL 雙主復制
- 08.雙主如何防止和解決主鍵沖突
- keepalived+haproxy+mysql雙主高可用
- lvs+keepalived+雙主mysql負載均衡
- MyCAT實現MySQL讀寫分離
- 09.多線程復制
- MHA
- 1.理解MHA高可用
- 2.搭建MySQL一主二從
- 3.建立節點互信
- 4.構建MHA
- 5.啟動并測試MHA
- 6.修復宕機的Master
- 重置root密碼
- MySQL 開發規范
- mycat
- 01.mycat 簡介與安裝
- 02.mycat 配置詳解
- 03.mycat 切片規則
- 常用SQL語句大全
- 01.取數騷SQL
- 02.評估表數據體量SQL
- Linux
- Contos 7
- 常用命令
- 解壓【zip】
- vmhgfs 掛載
- 跨主機免密碼認證
- 寶塔Linux面板
- 01.寶塔專業/企業版一鍵腳本破解版
- Windows
- 服務器
- 調出【桌面圖標】
- 查看【端口使用】
- 查看【操作日志】
- 查看【本地組策略】
- HTML
- URL編碼參照表
- RabbitMQ
- 01.rabbitMQ 快速入門
- 1. 認識 RabbitMQ
- 4. 消費者生產者代碼實例
- 3. 安裝 amqp 擴展
- 2. RabbitMQ安裝和啟動
- 02.rabbitMQ 高級特性
- 1. 高級特性前言
- 2. 高級特性之一ack comfirm機制
- 3. 高級特性之二如何保證消息的100%接收(一)
- 4. 高級特性之二如何保證消息的100%接收(二)
- 5. 高級特性之三冪等性
- 6. 高級特性之四 return機制
- 7. 高級特性之五 限流機制
- 8. 高級特性之六 重回隊列
- 9. 高級特性之七 TTL
- 10. 高級特性之八 死信隊列
- 03.tp6簡單應用 RabbitMQ
- 04.fanout 訂閱/廣播模式
- 05.topic 通配符模式
- Composer
- Composer 鏡像
- Compsoer 基礎使用
- Composer require 忽略依賴
- 微信公眾號
- 返回錯誤代碼說明
- 福利專區
- layuiAdmin框架模板
- Swoole
- 01.快速入門
- 1.swoole的概念介紹
- 2.安裝swoole
- 3. 快速運用swoole與理解
- 02.快速上手swoole與網絡協議
- 1.阻塞與非阻塞,同步與異步
- 2.HttpServer 加速php框架
- 3.WebSocket 簡單運用
- 4.tcp 與 upd 與 定時器
- 5.理解進程-非詳細
- 6.swoole結構
- 03.連接與tcp和upd
- 1.短鏈接與長連接
- 2.健康檢查
- 3.tcp 和 udp對比
- 4.tcp粘包的問題
- 5.tcp粘包問題的處理
- 04.理解網絡模型
- 1.linux內核與用戶空間調度
- 2.網絡io模型
- 3.構建worker結構iostar
- 4.理解stream系列函數
- 05.阻塞模型與非阻塞模型
- 1.構建基礎worker結構
- 2.搭建工程的結構
- 3.實現基礎版本的worker
- 4.完善worker模型
- 5.非阻塞模型與stream_select函數
- 6.補充
- 06.實現io復用與信號模型
- 07.實現異步io模型與Reactor模型
- 08.實現多進程reactor
- 09.詳解task進程
- 10.swostar之http與websocket
- 11.think-swoole使用
- 12.swostar之構建基礎核心結構
- 99.其他
- 西部數碼
- 01.NginxSLB搭建
- 02.windows 服務器取消多登錄
- PHP中高級面試題
- PHP基礎面試題
- MySQL面試題
- Redis面試題
- es面試題
- rqbbitMQ面試題
- 魔鬼訓練營
- 現場解答課-面試解答
- Laravel技術社區(干貨題庫匯總)
- 01.干貨題庫(一)
- 02.干貨題庫(二)
- 03.MySQL 常見面試題(1-25)
- 04.MySQL 常見面試題(26-58)
- Redis(2010期)
- 01.認識redis和安裝
- 02.Redis數據類型與string類型與list類型
- 03.Redis數據類型之hash類型與zset類型
- 04.Redis數據類型之set類型與性能檢測
- 05.Redis事務
- 06.Redis發布訂閱與stream應用
- 07.Redis-lua腳本
- 08.緩存擊穿,失效以及維度劃分
- 09.緩存穿透,雪崩問題
- 10.Redis緩存問題以及分布式鎖實現
- 11.redis持久化
- 1.redis-rdb持久化
- 2.redis-aof持久化
- 3.aof 和 rdb對比
- 12.redis主從復制
- 1.主從配置及原理
- 2.全量復制 和 部分復制
- 3.主從問題
- 13.redis哨兵機制
- 1.哨兵初識
- 2.redis哨兵原理
- 3.redis哨兵配置
- 4.redis哨兵問題
- 14.redis集群
- 1.集群搭建
- 2.故障轉移
- 3.redis集群伸縮
- 999.redis 常用命令
- key
- string(字符串)
- hash(哈希)
- list(列表)
- set(集合)
- zset(有序集合)
- Stream
- Redis 發布訂閱
- 事例
- Docker
- 1.docker快速入門
- 01.docker 了解
- 02.docker核心概念介紹
- 2.docker安裝
- 3.docker基本使用
- 01.常用命令(鏡像容器)
- 999.docker基本使用(示例)
- 01.docker部署es
- 02.docker部署lnmp
- 4.portainer可視化面板安裝
- 5.docker鏡像原理
- 01.docker鏡像聯合文件系統
- 02.docker分層理解
- 6.commit鏡像
- 7.docker容器數據卷
- 01.容器數據卷基本使用
- 02.容器數據卷示例
- 03.容器數據卷具名掛載和匿名掛載
- 04.多個容器數據卷數據共享
- 8.dockerFile
- 01.Dockerfile介紹
- 02.Dockerfile指令說明
- 03.發布鏡像到dockerhub
- 04.發布鏡像到阿里云
- 999.Dockerfile示例
- 01.Dockerfile構建 centos 鏡像
- 02.Dockerfile構建 tomcat 鏡像
- 03.Dockerfile構建 redis 鏡像
- 04.Dockerfile構建 lnmp 鏡像
- 9.docker網絡
- 01.理解docker0
- 02.容器互聯-link
- 03.自定義網絡
- 04.網絡互通
- 999.redis集群部署實戰
- 10.docker composer容器編排
- 01.docker-compose 介紹
- 02.安裝docker-compose
- 03.docker-compose 基本命令
- 04.docker-compose yml 常用命令
- 999.docker-compose示例
- 01.構建 nginx 鏡像(docker-compose)
- 02.構建 lnmp 鏡像(docker-compose)
- 11.docker swarm集群
- 12.ci/cd之jenkins
- 01.jenkins介紹
- 02.jenkins安裝(docker-compose)
- 13.k8s
- 01.什么是k8s
- 02.k8s使用場景
- 03.k8s部署架構分析
- 04.k8s運行架構分析
- Git
- 01.git理論和特點
- 02.gitlab安裝配置以及項目創建
- 03.用戶從windows接入并拉取+提交+修改代碼提交
- 04.如何把團隊弄進來一起開發
- 05.git基礎操作,練習命令
- 06.如果你讓三毛自己新建分支,并在上面開發這個時候三毛該怎么辦呢?
- 07.在分支開發完畢之后,如何合并到master
- 08.2個分支合并,發生沖突的演示,以及如何解決?
- 09.為什么要用git工作流,git工作流的好處
- 999.git常用命令
- phpstudy
- localhsot不顯示目錄
- tp6獲取不到header頭Authorization問題(apache)
- 分布式架構
- elk日志系統
- 01.elk為何而生
- 02.標準的日志系統包括哪些
- 03.什么是elk
- 04.架構設計分析
- 05.elk實操部署
- elasticsearch(簡稱:es)
- 01.es的簡介
- 02.es的安裝前提與安裝
- 03.es-head 與 kibana安裝
- 04.es的概念
- 05.ik分詞器
- 06.es對于restful的基本操作
- 07.es花式查詢
- 07.01 基本使用增刪改查
- 07.02 高級查詢
- 07.00 es花式搜索示例
- 01.大型互聯網架構演進過程
- 1.何為大型互聯網架構
- 2.分布式架構的演變過程
- 02.分布式通信技術介紹
- 1.分布式億級架構實戰
- 2.分布式-集群-微服務
- 3.分布式通信
- 4.分布式通信協議
- 03.分布式通信-實戰
- 1.分布式隊列原理
- 2.分布式隊列實戰
- 3.RPC代碼實戰
- 04.主流分布式架構設計詳解
- 1.分布式架構特性
- 2.CAP理論
- 3.BASE理論
- 05.consul服務注冊發現
- 1.consul的工作原理
- 2.consul集群實戰與操作
- 06.consul配置中心與實戰
- 1.配置中心是個什么
- 2.consul實現配置中心
- 3.consul的基本實戰操作
- 4.實戰跨服務調用
- 07.分布式數據庫
- 1.為什么要分庫分表
- 2.動態伸縮
- 08.分布式實戰數據庫實戰
- 09.分布式-分庫分表實戰
- 10.分布式事務
- 1.分布式事務
- 2.2PC-兩階段提交
- 3.3PC-三階段提交
- 4.TCC
- 5.MQ事務最終一致性
- 11.分布式實戰
- 12.elastic
- 13.elastic實戰
- 14.elastic場景實戰分析
- 15.elk
- 16.rabbitMQ
- 17.Kafka
- Redis、Nginx優化(2004期)
- 新能源汽車
- 數據表介紹
- 汽車租賃后臺管理
- 微信小程序授權
- 微信小程序接口
- Go
- Beego 框架
- 命令行大全
- go_zero
- 01.基礎部分
- 1.環境安裝并輸出HelloWorld
- 2.基礎語法與數據類型
- 3.Go語言變量常量定義
- 4.Go語言作用域
- 5.Go常用占位符
- 6.Go異常處理
- 7.Go中的包
- 8.指針與fmt
- 9.下劃線
- 10.數組(Array)
- 11.切片(Slice)
- 12.指針
- 13.Map
- 14.結構體
- 第三方庫
- 01.strconv
- 02.json
- 03.air實時加載
- 04.gjson
- 05.lo
- 06.time
- 07.reflect(反射)
- 08.retry-go(重試機制)
- 09.strings
- 數據庫操作
- 1.go操作mysql
- 2.go操作redis
- MongoDB
- 1.MongoDB 簡介
- 2.MongoDB 安裝
- 3.MongoDB 簡單CURD
- 4.MongoDB 條件操作符
- 5.MongoDB Limit/Skip/Sort方法
- 6.MongoDB 索引
- 7.MongoDB 聚合與管道
- 8.MongoDB 復制(副本集)
- 99. 客戶端安裝與PHP操作
- Swoft
- 01.框架安裝
- simpledingtalk修改點
- ThinkPHP6API基礎模板
- uniapp
- 01.微信小程序獲取頁面路由參數
- 02.通用提示
- 03.緩存
- 04.日期轉時間戳
- 05.VConsole調試
- Tailwind CSS
- 01.安裝以及基礎配置
- Vue
- 助手函數
- 1.時間戳格式化日期倒計時
- 2.獲取不重復的id
- 3.獲取正確的url路經
- 4.Object對象格式化為Query語法
- 5.數組轉Tree
- 6.Tree轉數組
- 7.判斷值是否為空
- 9.數字前置補零
- 10.在線時間
- 11.html轉義
- 12.pid形式數據轉children形式
- 13.遍歷children形式數據
- 14.全屏切換
- 15.獲取屏幕寬高度
- 16.獲取設備信息
- 17.百度高德地圖坐標轉換
- 18.深度克隆
- 19.獲取變量類型
- 20.播放音頻
- 21.導出excel
- 22.數字千分位
- 23.判斷是否是外鏈
- 24.獲取url參數
- ElementUI
- 1.表單驗證
- 模板
- Yii2
- 01.SQL慢查詢分塊