[TOC]

该目录下是语义流模拟生成程序的服务端源代码，将该工程导入Eclipse后，通过Eclipse的fatjar插件将该工程打包成名字为rdfserver.jar的包后通过命令行运行，命令行运行方式如下：

$ java -jar rdfserver.jar <each_num> <listening_port>

例如：

$ java -jar rdfserver.jar 10 30001

参数含义： <each_num> 模拟每类房间的个数 <listening_port> 服务端监听的端口号 在运行Spark Streaming程序之前，需要提前将该服务端程序启动。

该目录下是用于语义流处理的stream-processing程序。

单机运行主要是为了方便代码的编写和调试，可以直接在Eclipse环境下运行，运行前需要启动RDFServer服务端。 运行前，需要设置Eclipse运行的命令行参数如下：

com.stream.reasoning.AQIProcessing <master> <hostname> <port> <room_uri>

参数含义： <master> master节点位置，单机运行时设置为“local[2]” <hostname> RDFServer的IP地址 <port> RDFServer的监听端口 <room_uri> 目标房间的URI

com.stream.reasoning.BodyComfortProcessing <master> <hostname> <port> <room_uri>

<master> master节点位置，单机运行时设置为“local[2]” <hostname> RDFServer的IP地址 <port> RDFServer的监听端口 <room_uri> 目标房间的URI

com.stream.reasoning.QueryBySPARQL <master> <hostname> <port> <sparql_ip> <sparql_port>

<master> master节点位置，单机运行时设置为“local[2]” <hostname> RDFServer的IP地址 <port> RDFServer的监听端口 <sparql_ip> SPARQL语句导入程序的IP <sparql_port> SPARQL语句导入程序的端口号

com.stream.reasoning.QueryWindow <master> <hostname> <port> <sparql_ip> <sparql_port>

<master> master节点位置，单机运行时设置为“local[2]” <hostname> RDFServer的IP地址 <port> RDFServer的监听端口 <sparql_ip> SPARQL语句导入程序的IP <sparql_port> SPARQL语句导入程序的端口号

先用jps命令查看Master和Worker进程是否存在 若不存在，先执行

$SPARK_HOME/sbin/start-all.sh

集群运行主要是为了进行语义流处理的吞吐量实验。将stream-processing工程打包后生成stream-processing.jar包，放在discretized-semantic-stream根目录下。打开stream-processing.jar，删除/META-INF下除maven, *.RSA, *.MF以外的所有文件，然后通过两个脚本运行。

$ ./run-aqi stream-processing.jar com.stream.reasoning.AQIProcessing

$ ./run-aqi stream-processing.jar com.stream.reasoning.BodyComfortProcessing

先启动sparql-client

$ java -jar sparql-client.jar 30002

在该终端中输入SPARQL查询语句，例如

PREFIX p:<http://hem.org/predicate#>
SELECT ?value ?time WHERE {
<http://hem.org/room#bedroom_1> p:hasSensor ?sensor .
?sensor p:hasValue ?value .
?sensor p:valueType 'temp' .
?sensor p:samplingTime ?time . }

然后在另一终端里执行

$ ./run-sparql stream-processing.jar com.stream.reasoning.QueryBySPARQL

$ ./run-sparql stream-processing.jar com.stream.reasoning.QueryWindow

该工程下是对Spark运行日志进行分析的程序，运行后会生成包含分析结果的.xls文件。 命令行运行方式：

$ SparklogsAnalyzer <dir> <file_name>

参数含义： <dir> 日志所在目录 <file_name> 日志文件文件名