首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

Apache Kafka,Apache Pulsar和RabbitMQ的基准测试:哪一个是最快的MQ?

ApacheKafka是最流行的事件流处理系统。在这个领域中有很多同类的系统可以拿来比较。但是最关键的一点就是性能。Kafka以速度著称,但是,它现在能有多快,以及与其他系统相比又如何呢?我们决定在最新的云硬件上测试kafka的性能。 为了进行比较,我们选择了传统的消息broker RabbitMQ和基于Apache Bookeeper的消息broker Apache Pulsar。我们要关注以下几点,1.系统吞吐量。2.系统延迟。因为他们是生产中事件流系统的主要性能指标,特别是吞吐量测试测量每个系统在利用硬件(特别是磁盘和CPU)方面的效率。延迟测试测量每个系统交付实时消息的延迟程度,包括高达p99.9%的尾部延迟,这是实时和任务关键型应用程序以及微服务体系结构的关键需求。 我们发现Kafka提供了最好的吞吐量,同时提供了最低的端到端延迟,最高达到p99.9的百分比。在较低的吞吐量下,RabbitMQ以非常低的延迟交付消息。

04

centos安装RabbitMQ

1.安装Erlang环境(RabbitMQ由Erlang语言开发)  1.1)下载rpm安装包 官方地址:https://packages.erlang-solutions.com/erlang/ wget http://packages.erlang-solutions.com/site/esl/esl-erlang/FLAVOUR_1_general/esl-erlang_21.1.4-1~centos~6_amd64.rpm  1.2)安装Erlang rpm -ivh esl-erlang_21.1.4-1~centos~6_amd64.rpm 或者  1.1)安装Erlang Solutions仓库到你的系统(目的在于让你可以使用yum安装到最新版本的erlang, 如果不设置, yum安装的erlang版本通常太低) wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm rpm -Uvh erlang-solutions-1.0-1.noarch.rpm  1.2)yum install -y erlang 因为rabbitmq是使用erlang语言实现, 所以需要安装erlang依赖; 这里提供的RabbitMQ是最新版3.6.9, 所需的erlang版本最低为 R16B-03,否则编译时将失败  1.3)检查Erlang是否安装成功 [root@localhost ~]# erl -version Erlang (SMP,ASYNC_THREADS,HIPE) (BEAM) emulator version 10.1.3 2.安装RabbitMQ  2.1)下载rpm安装包 官方地址:http://www.rabbitmq.com/download.html wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.15/rabbitmq-server-3.6.15-1.el6.noarch.rpm  2.2)安装RabbitMQ yum -y install epel-release 之后执行yum -y install socat yum install -y rabbitmq-server-3.6.15-1.el6.noarch.rpm  2.3)检查RabbitMQ是否安装成功 rabbitmqctl status 3.关于服务  3.1)启动服务 service rabbitmq-server start  3.2)停止服务 service rabbitmq-server stop  3.3)设置开机启动 chkconfig rabbitmq-server on 4.用户管理  4.1)查看用户列表 [root@localhost ~]# rabbitmqctl list_users Listing users ... guest   [administrator]  4.2)添加用户     rabbitmqctl add_user 用户名 密码 [root@localhost ~]# rabbitmqctl add_user admin 123456 Adding user "admin" ...  4.3)删除用户     rabbitmqctl delete_user 用户名 [root@localhost ~]# rabbitmqctl delete_user admin Deleting user "admin" ...  4.4)修改用户密码     rabbitmqctl change_password 用户名 新密码 [root@localhost ~]# rabbitmqctl change_password admin 666666 Changing password for user "admin" ... 5.角色管理  5.1)角色说明 none(普通用户) 没有控制台操作权限。 management(普通管理员) 可以查看当前用户的queues, exchanges和bindings。 可以查看和关闭当前用户的channels和connections。 可以查看当前用户的virtual hosts的统计信息。 policymaker(策略管理员) 具有management权限及查看、创建和删除当前用户的policies和parameters。 monitoring(监控管理员) 具有management权限 查看所有virtual hosts及全局的统计信息 查看所有用户的connections和channels 查看所有节点数据,如clustering和me

02

日志系统

上一篇说了一下《解决问题的一般套路》,里面讲到了日志系统的重要性,日志重要吗?监控重要吗?of course!日志就是要能找到用户做了什么请求那个机器。上下游接口请求,请求参数和入参是否正确,我们可以统一写一个面向切面方法去打印日志,不用每一处去写,切入点大家自己按照规则定义,AOP是Spring提供的关键特性之一。 AOP即面向切面编程,是OOP编程的有效补充。使用AOP技术,可以将一些系统性相关的编程工作,独立提取出来,独立实现,然后通过切面切入进系统。从而避免了在业务逻辑的代码中混入很多的系统相关的逻辑——比如权限管理,事物管理,日志记录等等。这些系统性的编程工作都可以独立编码实现,然后通过AOP技术切入进系统即可。从而达到了 将不同的关注点分离出来的效果。

01
领券