作者：root
MQTT project for Spring Boot
项目地址：https://github.com/isilent-me/MQTT
参考项目：https://github.com/brandonbai/mqtt-spring-boot
订阅
mosquitto_sub -h localhost -t "test/#" -u hanmeimei -P 123456 -i "client1"
发布
mosquitto_pub -h localhost -t "test/abc" -u lilei -P 123456 -i "client3" -m "How are you?"
【转】在Spring Boot中使用MQTT
为什么选择MQTT
MQTT的定义相信很多人都能讲的头头是道,本文章也不讨论什么高大上的东西,旨在用最简单直观的方式让每一位刚接触的同行们可以最快的应用起来
先从使用MQTT需要什么开始分析:
- 消息服务器
- 不同应用/设备之间的频繁交互
- 可能涉及一对多的消息传递
根据上面列举的这三点,我们大概可以了解到, MQTT最适合的场景是消息做为系统的重要组成部分,且参与着系统关键业务逻辑的情形
MQTT, 启动!
既然决定使用它,我们首先要研究的是如何让MQTT正常工作,毕竟它不是简单的在maven里加入个依赖就完事的
我们总共需要干如下两件事:
- 下载EMQX消息服务器, 作为broker
- 在maven中引入依赖
<dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-mqtt</artifactId> <version>5.3.2.RELEASE</version> </dependency>
完成上面两步后, 启动EMQX服务器, 正式进入我们的MQTT旅途
使用方式
在Spring Boot中使用MQTT的代码, 笔者总结了如下两种方式:
- 使用spring-integration的消息通道概念
- 使用传统的Client客户端概念
第一种会产生一定程度的心智负担,但在笔者成功搭配(抄袭+造轮子)自动注册后, 比后者要方便许多
在介绍具体代码之前, 我们先简单整理下使用中最常见的概念:
- 主题: MQTT消息的主要传播途径, 我们向主题发布消息, 订阅主题, 从主题中读取消息并进行业务逻辑处理, 主题是消息的通道
- 生产者: MQTT消息的发送者, 他们向主题发送消息
- 消费者: MQTT消息的接收者, 他们订阅自己需要的主题, 并从中获取消息
- broker: 消息转发器, 消息是通过它来承载的, EMQX就是我们的broker, 在使用中我们不用关心它的具体实现
其实, MQTT的使用流程就是: 生产者给主题发消息->broker进行消息的传递->订阅该主题的消费者拿到消息并进行相应的业务逻辑
MQTT相关文章
【转】Linux Ubuntu 查找文件命令 mlocate 安装和使用方法
转载自：Linux Ubuntu 查找文件命令 mlocate 安装和使用方法
在 Linux 系统中查找文件是一个比较头大的事情，毕竟不像 Windows 那么方便，没有很方便的可视化界面，也没有很好用的搜索框（指服务器）。所以在 Linux 中查找文件还是需要学习一下怎么操作的，本文分享一个比较方便的工具 mlocate，可以在 Linux 包括 Ubuntu 等系统中快速的查找文件。
一、安装 mlocate 并更新数据库
在 Ubuntu、Debian 上安装：
apt-get install mlocate
安装之后，没有数据库，直接使用会报错：
root@vnc:~# locate hosts locate: can not stat () `/var/lib/mlocate/mlocate.db': No such file or directory
所以需要更新一下数据库：
# time updatedb real 0m0.593s user 0m0.018s sys 0m0.112s
一般来说可能需要几秒钟到几分钟的时间来完成更新，配置低的可能需要时间更久。
可以看一下更新之后的数据库长啥样：
root@vnc:~# locate -S Database /var/lib/mlocate/mlocate.db: 3,260 directories 33,859 files 1,433,462 bytes in file names 640,990 bytes used to store database
二、使用 mlocate 查找文件
使用 root 进行查询：
root@vnc:~# locate hosts /etc/hosts /etc/hosts.allow /etc/hosts.deny /usr/lib/x86_64-linux-gnu/security/pam_rhosts.so /usr/share/man/man5/hosts.5.gz /usr/share/man/man5/hosts.allow.5.gz /usr/share/man/man5/hosts.deny.5.gz /usr/share/man/man5/hosts.equiv.5.gz /usr/share/man/man5/hosts_access.5.gz /usr/share/man/man5/hosts_options.5.gz /usr/share/man/man8/pam_rhosts.8.gz /usr/share/vim/vim81/ftplugin/denyhosts.vim /usr/share/vim/vim81/ftplugin/hostsaccess.vim /usr/share/vim/vim81/syntax/denyhosts.vim /usr/share/vim/vim81/syntax/hostsaccess.vim /usr/share/zsh/vendor-completions/_sd_hosts_or_user_at_host
查询同样会有权限限制。如果是 root 账户，是可以查询到其他人账户下的文件的，比如 Mary 账户下的文件：
# locate entry1.txt /home/mary/diary/entry1.txt
但是不是 root 账户就无法看到其他人账户下的文件：
# su - frank $ locate entry1.txt $
一般来说，每晚会自动更新数据库。
以上就是 Ubuntu/Debian 使用 mlocate 查找文件的方法。
CentOS 7 防火墙firewall-cmd常用命令
firewall-cmd常用命令 #开启防火墙 systemctl start firewalld #防火墙开机启动 systemctl enable firewalld #关闭防火墙 systemctl stop firewalld #查看防火墙状态 firewall-cmd --state #查看现有的规则 iptables -nL firewall-cmd --zone=public --list-ports #重载防火墙配置 firewall-cmd --reload #添加单个单端口 firewall-cmd --permanent --zone=public --add-port=81/tcp #添加多个端口 firewall-cmd --permanent --zone=public --add-port=8080-8083/tcp #删除某个端口 firewall-cmd --permanent --zone=public --remove-port=81/tcp #添加操作后别忘了执行重载 firewall-cmd --reload
参考链接：
【转】Linux wget 403 forbidden错误解决方法
转载自：Linux wget 403 forbidden错误解决方法
wget是Linux常用命令，用于下载远程文件，一直以来使用都非常顺畅，这次却遇到提示403 forbidden错误，在浏览器直接输入下载地址却能正常下载。
在wget时使用-U参数就正常了，原因是资源服务器限制了访问代理，这里加上-U参数设定了代理名称，就可以正常下载了。
另外还有一种情况是资源所在目录没有权限，也会返回403错误，这种情况使用浏览器下载也会报错。
wget -U NoSuchBrowser/1.0 下载地址
linux ll 以m来显示文件列表中每个文件的大小
ll -h
根据url批量下载图片
修改自：根据url批量下载图片
根据url.txt，下载图片至当前目录images下：
import requests
with open("url.txt","r") as f:
urls = [cname.strip() for cname in f.readlines()]
for url in urls:
print(url)
pic = requests.get(url)
name="./images/"+url.split("/")[-2]+"/"+url.split("/")[-1]
print(name)
with open(name, 'wb') as f:
f.write(pic.content)