redis和kafka的写性能对比
kafka插入代碼如下所示:
<?php
$conf = new RdKafka\Conf();
$rk = new RdKafka\Producer($conf);
$rk->setLogLevel(LOG_DEBUG);
$rk->addBrokers("127.0.0.1");
$cf = new RdKafka\TopicConf();
// -1必須等所有brokers同步完成的確認 1當前服務器確認 0不確認,這里如果是0回調里的offset無返回,如果是1和-1會返回offset// 我們可以利用該機制做消息生產的確認,不過還不是100%,因為有可能會中途kafka服務器掛掉
$cf->set('request.required.acks', 0);
$topic = $rk->newTopic("test", $cf);
$option = 'huancai';
for ($i = 0; $i < 20; $i++) {
? ? //RD_KAFKA_PARTITION_UA自動選擇分區
? ? //$option可選
? ? $topic->produce(RD_KAFKA_PARTITION_UA, 0, "huancai . $i", $option);
}
?>
redis插入代碼如下所示:
<?php
//echo '999';
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
//$key = 'piao';
//$value = $redis->get($key);
//var_dump($value);
for ($i = 0; $i < 20; $i++) {
? ? $redis->set("huancai . $i","huancai.$i");
}
?>
10個并發10000個請求ab壓測后kafka的執行效果如下所示:
10個并發10000個請求ab壓測后redis的執行效果如下所示:
從上面壓測結果可以看出,redis比kafka的寫入速度要快好多。
總結
以上是生活随笔為你收集整理的redis和kafka的写性能对比的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: redis、kafka、rabittMQ
- 下一篇: kafka删除主题数据和删除主题