福和思

## 下载后解压安装
tar -xzf kafka_2.13-3.2.1.tgz
cd kafka_2.13-3.2.1

## 启动zookeeper、kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

## 创建topic并检查
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
### 查看所有topic
bin/kafka-topics.sh  --bootstrap-server localhost:9092 --list

## 生产者-消费者
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

kafka 可视化界面管理

tar zxvf kafka-eagle-bin-3.0.0.tar.gz 
cd kafka-eagle-bin-3.0.0
tar zxvf efak-web-3.0.0-bin.tar.gz 
cd efak-web-3.0.0

vi /etc/profile
export KE_HOME=~/soft/kafka-eagle-bin-3.0.0/efak-web-3.0.0
export PATH=.:$PATH:$KE_HOME/bin
source /etc/profile

vi system-config.properties 
## 修改相关配置
efak.zk.cluster.alias=cluster1
cluster1.zk.list=localhost:2181
efak.url
efak.password

./ke.sh start
localhost:8048
admin/123456

问题1: 不能看到消息内容
进入topic后，有个眼睛，预览功能

springboot 整合

鉴权

运维

问题1: 如何保证消息不丢失
问题2: 如何保证不重复消费
问题3:

附录

钉钉&&企微-消息发送

发表于 2022-07-28 更新于 2022-08-12 分类于 02专题， 02-05 消息推送阅读次数：

消息推送

钉钉

1、获取企业内部应用的access_token

1	get https://oapi.dingtalk.com/gettoken?appkey=&appsecret=

2、发送通知

post https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2?access_token=

{
    "msg":{
        // "voice":{
        //     "duration":"100",
        //     "media_id":"100"
        // },
        // "image":{
        //     "media_id":"@123"
        // },
        // "oa":{
        //     "head":{
        //         "bgcolor":"bgcolor",
        //         "text":"text"
        //     },
        //     "pc_message_url":"pc_message_url",
        //     "status_bar":{
        //         "status_value":"进行中",
        //         "status_bg":"0xFFF65E5E"
        //     },
        //     "body":{
        //         "file_count":"file_count",
        //         "image":"image",
        //         "form":{
        //                 "value":"value",
        //                 "key":"key"
        //         },
        //         "author":"author",
        //         "rich":{
        //                 "unit":"unit",
        //                 "num":"num"
        //         },
        //         "title":"title",
        //         "content":"content"
        //     },
        //     "message_url":"message_url"
        // },
        // "file":{
        //     "media_id":"media_id"
        // },
        // "action_card":{
        //     "btn_json_list":{
        //             "action_url":"action_url",
        //             "title":"title"
        //     },
        //     "single_url":"single_url",
        //     "btn_orientation":"btn_orientation",
        //     "single_title":"single_title",
        //     "markdown":"markdown",
        //     "title":"title"
        // },
        // "link":{
        //     "picUrl":"picUrl",
        //     "messageUrl":"messageUrl",
        //     "text":"text",
        //     "title":"title"
        // },
        // "markdown":{
        //     "text":"text",
        //     "title":"title"
        // },
        "text":{
            "content":"测试使用钉钉消息推送"
        },
        "msgtype":"text"
    },
    "to_all_user":"false",
    "agent_id": "1752362252",
    "dept_id_list":"606709116",
    // "userid_list": "014266190220645721"
}

企微

1、获取access_token

1	get https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=&corpsecret=

2、发送消息

post https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=

{
   "touser" : "UserID1|UserID2|UserID3",
   "toparty" : 1,
   "totag" : "TagID1 | TagID2",
   "msgtype" : "text",
   "agentid" : 1000003,
   "text" : {
       "content" : "你的快递已到，请携带工卡前往邮件中心领取。\n出发前可查看<a href=\"http://work.weixin.qq.com\">邮件中心视频实况</a>，聪明避开排队。"
   },
   "safe":0,
   "enable_id_trans": 0,
   "enable_duplicate_check": 0,
   "duplicate_check_interval": 1800
}

centos 开机启动

发表于 2022-06-02 分类于 05 笔记， 51 开发环境阅读次数：

开机启动服务设置

准备

待执行的命令 startup.sh

1
2
3

nacos/bin/startup.sh

chmod -x ~/nacos/bin/startup.sh

设置服务 nacos

vi /usr/lib/systemd/system/nacos.service

[Unit]
Description=nacos
Documentation=
After=network.target
Wants=
Requires=

[Service]
ExecStart=/bin/bash ~/nacos/bin/startup.sh -m standalone
ExecStop=
ExecReload=/bin/bash ~/nacos/bin/startup.sh -m standalone
Type=forking

[Install]
WantedBy=multi-user.target

验证

#nacos.service位于/usr/lib/systemd/system

#设置开机启动（设置开机启动执行这个就行）
systemctl enable nacos.service

#启动服务——执行后就生效
systemctl start nacos.service

#显示服务状态——如果脚本执行失败，这条命令可以帮助你看到脚本的报错信息
systemctl status nacos.service