可以先阅读:nameko 投递信息不持久化
投递 1000 bytes 的 message(不开持久化)
文章图片
速率在 2000+
投递 100 KB 的 message(不开持久化)
文章图片
速率在 1500左右
投递 10MB 的 message(不开持久化)
文章图片
速率在 35 左右
【nameko 投递不同大小消息的速率对比】参考代码:
from loguru import logger
import settings
from nameko.standalone.events import event_dispatcher
from nameko.constants import NON_PERSISTENT
import timeconfig = {
'AMQP_URI': f'amqp://{settings.RABBITMQ_CONFIG.username}:'
f'{settings.RABBITMQ_CONFIG.password}@{settings.RABBITMQ_CONFIG.host}:'
f'{settings.RABBITMQ_CONFIG.port}/{settings.RABBITMQ_CONFIG.vhost}'
}data='https://www.it610.com/article/1234567890'*1000*1000dispatch = event_dispatcher(config,delivery_mode=NON_PERSISTENT)
for _ in range(100000):
dispatch(
'test_publishe',
'to_publish',
data
)