zoukankan      html  css  js  c++  java
  • 初试kafka消息队列中间件一 (只适合初学者哈)

    初试kafka消息队列中间件一

    今天闲来有点无聊,然后就看了一下关于消息中间件的资料, 简单一点的理解哈,网上都说的太高大上档次了,字面意思都想半天; 也就是用作消息通知,比如你想告诉某某你喜欢他,或者要开会了,通知给哪些人; 可以分不同的主题,不同的接受方式。


    我这也是第一次动手哈,以前都只是看理论知识; 理论大家www.baidu.com一番都了解的七七八八了哈 ,我就直接上动手的过程了。


    需要先进行下载; 这里是下载地址http://kafka.apache.org/downloads; 如下图


    下载完成后选择合适的目录进行解压即可,本案例是在windos环境下进行的;如下图


    上面已经下载完成了、接下来就是要进行启动,然后进行测试了;


    打开你解压的文件,G:下载4kafka_2.11-2.3.0把这个换成你自己的路径;

    在地址栏输入cmd回车或者shift+鼠标右键都行。代表在当前目录打开命令行;

    输入命令:.inwindowszookeeper-server-start.bat .configzookeeper.properties;. 代表当前目录,使用这个bat启动Zookeeper并且使用后边的配置。

    出现如下图并且没有什么错误代表启动成功。


    启动Kafka

    同样的路径,再打开一个新的命令行窗口;输入命令:.inwindowskafka-server-start.bat .configserver.properties


    现在需要启动的都已经启动了,打开的命令行窗口别关闭;

    现在我们需要创建一个主题,也就相当于消息的类型,就叫msg1吧

    进入的文件目录inwindows下,再次打开一个新的命令行窗口;

    输入创建主题命令:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic msg1


    现在消息的主题已经创建了

    接下来创建发送消息的生产者,用于发送消息

    进入的文件目录inwindows下,再次打开一个新的命令行窗口;

    输入创建消息发送命令:kafka-console-producer.bat --broker-list localhost:9092 --topic msg1


    最后一步创建接受消息的消费者,用于接受消息

    进入的文件目录inwindows下,再次打开一个新的命令行窗口;

    输入创建接收消息命令:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic msg1 --from-beginning


    最后就是测试了,我们在发送消息的窗口输入信息,在接受信息的窗口上就可以收到了;如下图:


    好了,测试完毕;大家可以自行多创建几个主题多开几个窗口进行不同的主题发送试试看!

    下次有时间我再整理到项目中用代码写案例了,有想一起学习了童鞋们可以加一波关注哈!!!!


  • 相关阅读:
    上传几张智能开关产品图片
    python+ueditor+七牛云存储整合
    Shell脚本检查memcache进程并自己主动重新启动
    Cocos2dx 3.x创建Layer的步骤
    HDU 5009 Paint Pearls (动态规划)
    (转)Spring4.2.5+Hibernate4.3.11+Struts2.3.24整合开发
    (转)Spring提供的CharacterEncoding和OpenSessionInView功能
    (转)为Spring集成的Hibernate配置二级缓存
    (转)Spring4.2.5+Hibernate4.3.11+Struts1.3.8集成方案二
    (转)Spring4.2.5+Hibernate4.3.11+Struts1.3.8集成方案一
  • 原文地址:https://www.cnblogs.com/qq376324789/p/11316895.html
Copyright © 2011-2022 走看看