什么是Pulsar
pulsar是一个多租户、高性能server-to-srever消息解决方案,最初由雅虎开发,现在由apache维护。
Pulsar的核心特性:
- Pulsar-functions;serverless轻量级计算框架
架构设计
![](https://img-blog.csdnimg.cn/20210721083155571.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYWp1bjA3MDYxMjI1,size_16,color_FFFFFF,t_70)
本地启动并收发第一条消息
进入下载页,下载稳定版本binary:
https://pulsar.apache.org/download/
直接解压,可以发现有如下几个目录:
- bin:命令行工具
- conf:各种配置文件(broker配置、zk配置等)
- examples:包含了函数使用示例的一个jar文件
- lib:pulsar依赖的jar包
运行如下命令单机启动:
./pulsar standalone -nss
新开一个终端,启动消息消费端:
./pulsar-client consume my-topic -s "first-subscription"
![](https://img-blog.csdnimg.cn/img_convert/6f2de60c41b10e51a51710ea0d35c5aa.png)
启动了对topic(my-topic)的订阅。
然后运行如下命令发送一个测试消息:
./pulsar-client produce my-topic --messages "hello-pulsar"
可以看到消息发送成功:
![](https://img-blog.csdnimg.cn/img_convert/ad9443037689201a0abd900b4a69308a.png)
在消费端可以看到成功消费了消息:
![](https://img-blog.csdnimg.cn/img_convert/23c4f54ffdb6f411ebf02a078afe1a2b.png)
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)