发表于 | 分类于
| 字数统计 341 | 阅读时长 1

使用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库文件的压缩包格式
阅读全文 »

发表于 | 分类于
| 字数统计 62 | 阅读时长 0 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONException;
import com.alibaba.fastjson.JSONObject;
/**
 * 判断是不是json
 * 暴力解析:Alibaba fastjson
 * @param test
 * @return
 */
public final static boolean isJSONValid(String test) {
    try {
            JSONObject.parseObject(test);
    } catch (JSONException ex) {
        try {
            JSONObject.parseArray(test);
        } catch (JSONException ex1) {
                return false;
        }
    }
        return true;
}
阅读全文 »

发表于 | 分类于
| 字数统计 152 | 阅读时长 0

参数选项

  • Include.NON_DEFAULT 属性为默认值不序列化
  • Include.NON_EMPTY 属性为 空（“”） 或者为 NULL 都不序列化
  • Include.NON_NULL 属性为NULL 不序列化

方法过滤

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.annotation.JsonInclude.Include;
import com.fasterxml.jackson.core.JsonProcessingException;
/**
 * jackson to fastjson
 * 
 * @param obj
 * @return
 */
public static Object NON_DEFAULT(Object obj) {
		try {
			obj = new ObjectMapper().setSerializationInclusion(Include.NON_DEFAULT).writeValueAsString(obj);
		} catch (JsonProcessingException e) {
			e.printStackTrace();
		}
		return obj;
	}

注解过滤

1
2
3
4
5
6
7
import com.fasterxml.jackson.annotation.JsonInclude;
public class APIResultBean<T> implements Serializable{
	private static final long serialVersionUID = 1L;
	// 过滤空值
	@JsonInclude(JsonInclude.Include.NON_DEFAULT)
	private T data;
}
阅读全文 »

发表于 | 分类于
| 字数统计 747 | 阅读时长 3

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
阅读全文 »

发表于 | 分类于
| 字数统计 607 | 阅读时长 3

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();
		}
	}
阅读全文 »

今日诗词

作者信息