Mosquitto 是一个MQTT代理服务器

安装

1

sudo apt install mosquitto

查看帮助

1

mosquitto --help

mosquitto [-c config_file] [-d] [-h] [-p port]

• -c : specify the broker config file.
• -d : put the broker into the background after starting.
• -h : display this help.
• -p : start the broker listening on the specified port.
• Not recommended in conjunction with the -c option.
• -v : verbose mode - enable all logging types. This overrides
• any logging options given in the config file.

修改配置文件

1

vim /etc/mosquitto/mosquitto.conf

运行

1

sudo systemctl start mosquitto

停止

1

sudo systemctl stop mosquitto

关于Almanac

Almanac

AlmanacAPP

本项目类似寿星天文历和日梭万年历
我只是代码的搬运工！如有侵权，联系删除。联系邮箱：1161946342@qq.com

• 西历 公历 阳历
• 农历 阴阳历 黄历
• 伊斯兰历 回历 阴历
• 儒略历 格里历
• 天文历
• 黄帝纪年 黄帝历 古六历
• 寿星天文历
• 日梭万年历
• 紫金天文台
• 中华农历网
• 时间科普
• 中国科学院国家授时中心
• 中国科学院紫金天文台
• 电子天文历表
• 天之文

感谢

wangpeng047
lxslove
moodlxs
hanoi

类介绍

• AlmanacBean.java：实体类
• Almanac.java：接口
• AlmanacImpl.java：实现类
• Annals.java：纪年表类(农历，节假日，纪年表等数据表)
• AreaUtil.java：地址工具类
• AstronomyArithmetic.java：天文算法类
• Common.java：公用天文数据类
• DataBean.java：时间位置实体类
• FestivalAndHoliday.java：节假日计算类
• IslamicCalendar.java：伊斯兰历（回历）算法类
• JulianCalendar.java：儒略日计算类
• LunarCalendar.java：农历数据类
• Port.java：港口计算类
• Propt.java：配置文件加载类
• QiShuo.java：气朔计算和参数数据表类
• SolarTermUtil.java：24节气工具类
• SunAndMoon.java：日出日落时间计算类（根据配置文件的中经纬度和公历时间）
• TimeUtil.java：时间工具类（格式，类型转换等）

说明

old文件夹下4个源码包是旧版本的，由于改动比较大，所以没有删掉。请忽略。

bug

• 时间无法进入公元前

不足

• 天文历信息不足：方位、赤纬、时角、黄经、黄纬，潮汐，太阳高度角，地球直射位置，地球远日点，地球近日点，日食月食等

程序运行效果展示

Almanac APP 演示

Almanac APP 下载

点击下载

编译

1

javac ./com/almanac/main/Main.java 

运行

1

java com.almanac.main.Main

2Mic麦克风阵列与4Mic麦克风阵列

使用本人修改的开源的SDK的教程

运行环境及依赖

• Python2.7.14
• gstreamer1.0
• gstreamer1.0-plugins-good
• gstreamer1.0-plugins-ugly
• python-gi
• python-gst
• gir1.2-gstreamer-1.0

Ⅰ : 树莓派 Raspberry Pi 3 Model B

使用GitHub项目安装

克隆项目

1

git clone https://github.com/HuangDayu/Raspberry-TensorFlow.git

安装TensorFlow库

1

sudo pip3 install  tensorflow-1.1.0-cp34-cp34m-linux_armv7l.whl

克隆基础模型

1

1

git clone https://github.com/tensorflow/models.git

将模型文件夹移动到TensorFlow项目下

1

1

sudo mv /home/pi/models /usr/local/lib/python3.4/dist-packages/tensorflow

使用shell脚本运行项目

1

sh UserTensorFlow.sh cat.jpg

• cat.jpg 是需要TensorFlow需要识别的图片
• 第一次执行会比较慢，需要联网下载深度学习图像识别库model

使用官方方法安装

安装依赖

1

sudo apt-get install python3-pip python3-dev

下载库文件

1

wget https://github.com/samjabrahams/tensorflow-on-raspberry-pi/releases/download/v1.1.0/tensorflow-1.1.0-cp34-cp34m-linux_armv7l.whl

安装TensorFlow

1

sudo pip3 install tensorflow-1.1.0-cp34-cp34m-linux_armv7l.whl

克隆模型

1

1

git clone https://github.com/tensorflow/models.git

将模型文件夹移动到TensorFlow项目下

1

1

sudo mv /home/pi/models /usr/local/lib/python3.4/dist-packages/tensorflow

新建文件夹并且将需要识别的图片保存到该目录下

1

mkdir /home/pi/Raspberry-TensorFlow

运行识别脚本

1

sudo python3 /usr/local/lib/python3.4/dist-packages/tensorflow/models/tutorials/image/imagenet/classify_image.py --model_dir /home/pi/tensorflow/model --image_file /home/pi/tensorflow/cat.jpg

说明

• /usr/local/lib/python3.4/dist-packages/tensorflow/models/tutorials/image/imagenet 这个路径是TensorFlow的 Python图像分类程序 classify_image.py 所在的路径。
• –model_dir 参数传入的是我们前面解压出来的模型文件所在的路径，在model文件夹里面已经自动下载并解压了inception-2015-12-05.tgz，它是tensorflow的一个深度学习图像识别库。
• –image_file 是我们需要别识别的图片的路径。
• .whl文件是python库文件的压缩包格式

Apache-Apollo 是一个MQTT代理服务器

下载安装包

1

wget http://mirrors.tuna.tsinghua.edu.cn/apache/activemq/activemq-apollo/1.7.1/apache-apollo-1.7.1-unix-distro.tar.gz

创建实例

1
2
3
4
5

cd ./apache-apollo-1.7.1/bin

./apollo create mqttbroker

设置开机自启动服务

1

sudo ln -s "/root/apache-apollo/apache-apollo-1.7.1/bin/mqttbroker/bin/apollo-broker-service" /etc/init.d/apollo-broker-service start

修改配置文件

1

vim apollo.xml 

运行实例

1

./apache-apollo/apache-apollo-1.7.1/bin/mqttbroker/bin/apollo-broker run

结束实例

1
2

# 46535 是进程pid
killall 46535 -9 

端口

• 代理服务 61680
• 客户端 61613

账户和密码

• 账户 admin
• 密码 password

实例mqttbroker下的目录解释

• bin 运行脚本
• etc 环境配置
• data 存储持久化数据
• log 运行日志
• tmp 临时文件
• etc文件夹下配置文件说明
• • users.properties：
• • • 用来配置可以使用服务器的用户以及相应的密码。
• • • 其在文件中的存储方式是：用户名=密码，如：
• • • admin=password
• • • 表示新增一个用户，用户名是：admin，密码是：password
• • groups.properties：
• • • 持有群体的用户映射，可以通过组而不是单个用户简化访问控制列表。

• • • 可以为一个定义的组设置多个用户，用户之间用“

      ”隔开，如：

• • • admins=admin

      lily

• • • 表示admins组中有admin和lily两个用户
• • black-list.txt
• • • 用来存放不允许连接服务器的IP地址，相当于黑名单类似的东西。
• • • 例如：10.20.9.147
• • • 表示上面IP不能够连接到服务器。
• • login.config：
• • • 是一个服务器认证的配置文件，为了安全apollo1.6版本提供了认证功能，只有相应的
• • • 用户名和正确的密码才能够连接服务器。
• • 服务器主配置文件apollo.xml：
• • • 该配置文件用于控制打开的端口，队列，安全，虚拟主机设置等。
• • • • 认证：可以使用<authenticationdomain=”internal” />来配置是否需要连接认证，如果将其属性enable设置为false表示不用认证，任何人都可以连接服务器，默认为true
• • • • access_rule：可以在broker或者virtual_host中用于定义用户对服务器资源的各种行为。如：表示群组users里面的用户可以对服务器资源进行的操作有：connect 、create、 destroy、 send 、receive 、consume。详细的操作说明见：http://activemq.apache.org/apollo/documentation/user-manual.html
• • • • message stores：默认情况下apollo使用的是LevelDB store，但是推荐使用BDB store（跨平台的）只能够实用其中一种。使用LevelDB store的配置是：默认有提供不用任何修改。使用BDB store需要到网站下jar包支持http://download.oracle.com/maven/com/sleepycat/je/5.0.34/je-5.0.34.jar，将jar包放在服务器的lib目录下面，然后将配置文件改成：即可。
• • • • connector：用于配置服务器支持的链接协议以及相应的端口。如：
• • • • <connector id=”tcp” bind=”tcp://0.0.0.0:61613” connection_limit=”2000”
• • • • protocol=”mqtt”/>表示支持tcp链接，使用的端口是61613，链接限制是2000，
• • • • 自动侦听的协议是mqtt协议。
• • 具体查看：http://activemq.apache.org/apollo/documentation/user-manual.html

EMQTT 是一个MQTT代理服务器

下载编译之后的软件包

1
2

wget http://emqtt.com/static/brokers/emqttd-ubuntu16.04-v2.3.6.zip
sudo unzip emqttd-ubuntu16.04-v2.3.6.zip

打开

1

./emqttd/bin/emqttd start

关闭

1

./emqttd/bin/emqttd stop

查询状态

1

./emqttd/bin/emqttd_ctl status

通过API发送消息给EMQTT代理服务器

Http Post To EMQTT 封装

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ConnectionRequest;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.params.CoreConnectionPNames;
import org.apache.http.util.EntityUtils;
public static void httpAPIPublishMqttPayload(String json) {
		final Base64.Encoder encoder = Base64.getEncoder();
		byte[] textByte;
		// 编码
		String encodedText=null;
		try {
			textByte = "admin:public".getBytes("UTF-8");//对账号和密码进行编码
			encodedText = encoder.encodeToString(textByte);// 编码
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
		RequestConfig config = RequestConfig.custom().setConnectTimeout(5000).setSocketTimeout(3000).build();
		HttpClient httpClient = HttpClientBuilder.create().setDefaultRequestConfig(config).build();

		HttpPost httppost = new HttpPost(“http://yibuwulianwang.com:18000/api/v2/mqtt/publish”);

		httppost.setHeader("Authorization", "Basic " + encodedText);
		httppost.setHeader("Content-Type", "application/json");
		// httppost.setHeader("Content-Length", String.valueOf(postStrBytes.length));

		String postjson = JSON.toJSONString(“json”));//payload json
		// 构建消息实体
		StringEntity entity = new StringEntity(postjson, Charset.forName("UTF-8"));
		entity.setContentEncoding("UTF-8");
		// 发送json格式的请求
		entity.setContentType("application/json");
		httppost.setEntity(entity);

		HttpResponse response;
		try {
			response = httpClient.execute(httppost);
			// 消息返回码
			int statusCode = response.getStatusLine().getStatusCode();
			if (statusCode != HttpStatus.SC_OK) {
				System.out.println("REQUEST EMQTT HTTP API ERR:" + statusCode);
			} else {
				System.out.println("REQUEST EMQTT HTTP API SUCCESS:" + statusCode);
			}
			HttpEntity httpEntity = response.getEntity();
			String result = null;
			if (httpEntity != null) {
				result = EntityUtils.toString(httpEntity, "utf-8");
				EntityUtils.consume(httpEntity);
				System.out.println("EMQTT HTTP API RESPONSE RESULT:"+result);
			}
		} catch (ClientProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

Http Post 封装

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

import java.io.IOException;
import java.nio.charset.Charset;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
public void postAPI(String url, Object json) {
		RequestConfig config = RequestConfig.custom().setConnectTimeout(35000).setConnectionRequestTimeout(35000)
				.setSocketTimeout(60000).build();
		HttpClient httpClient = HttpClientBuilder.create().setDefaultRequestConfig(config).build();
		HttpPost httpPost = new HttpPost(url);
		httpPost.setHeader("Content-Type", "application/json");
		String postjson = JSON.toJSONString(json);
		System.out.println("请求接口( " + url + " )的数据：\n" + postjson);
		StringEntity entity = new StringEntity(postjson, Charset.forName("UTF-8"));
		entity.setContentEncoding("UTF-8");
		entity.setContentType("application/json");
		httpPost.setEntity(entity);
		try {
			HttpResponse httpResponse = httpClient.execute(httpPost);
			HttpEntity httpEntity = httpResponse.getEntity();
			String result = EntityUtils.toString(httpEntity, "utf-8");
			EntityUtils.consume(httpEntity);
			System.out.println("接口( " + url + " )响应的数据：\n" + result);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}