导语:前面我们介绍了消息队列也比较了各种消息队列,接下来创建一个CKafka来测试一下。
第 1 步:登录控制台
登录腾讯云控制台。
第 2 步:创建 CKafka 实例
进入 消息队列 CKafka 界面,点击新建按钮,填写相关配置并选择实
例类型,创建实例。
创建成功后,点击上图的ID/名称中的ID,进入实例的基本信息页面:
第 3 步:创建topic
在右边的topic管理创建topic:
再创建topic时就会显示:
可以修改topic的最大消息的大小限制,范围0B到8MB。
第 4 步:创建一台云服务器,并安装JDK环境
下载JDK
https://www.oracle.com/technetwork/java/javase/downloads/java-archive-downloads-javase7-521261.html
注册个账号并下载JDK,上传云主机上:
登入主机
移动到固定文件夹并解压缩
mkdir /usr/local/jdk mv jdk-7u79-linux-x64.tar.gz /usr/local/jdk/ cd /usr/local/jdk/ tar -xzvf jdk-7u79-linux-x64.tar.gz
配置环境变量 vim /etc/profile 在文件末尾加入如下环境变量的配置: export JAVA_HOME=/usr/local/jdk/jdk1.7.0_79 export JRE_HOME=/usr/local/jdk/jdk1.7.0_79/jre export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH export CLASSPATH=.:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:$JRE_HOME/lib
第 5 步:下载 Kafka 工具包并上传到云主机中
下载地址:http://kafka.apache.org/downloads
这里面的下载后解压直接可用
第 6步:创建用户并配置ACL策略,实现公网用户认证,生产和消费
配置生产和消费者的配置文件:
cat /opt/kafka_2.10-0.10.2.0/config/producer.properties
cat /opt/kafka_2.10-0.10.2.0/config/server.properties
sasl.mechanism=PLAIN ###用户客户端连接的SASL机制
security.protocol=SASL_PLAINTEXT ###用于与CKafka代理节点进行通信的协议
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=“实例ID
#username” password=“password”; ###设置实例ID#用户名和密码
第 7步:测试使用用户认证生产消费消息
生产消息:cd /opt/kafka/bin & ./kafka-console-producer.sh --broker-list 123.206.249.190:9092 --topic face-car --producer.config ../config/producer.properties
消费消息:cd /opt/kafka/bin & ./kafka-console-consumer.sh --bootstrap-server 123.222.222.190:9092 --new-consumer --topic face-car --consumer.config ../config/consumer.properties
下一章将去看看消息队列CKafka管理界面的配置和参数设置