|
")
}
}
构建工程
进入目录AkkaSampleApp。运行：
sbt package
第一次运行时间会比较长。
测试应用
启动Spark服务
$SPARK_HOME/sbin/start-master.sh
master服务，默认会使用7077这个端口。可以通过其日志文件查看实际的端口号。
$SPARK_HOME/sbin/start-slave.sh spark://$(hostname):7077
启动Akka Server应用
运行：
$SPARK_HOME/bin/spark-submit --master spark://$(hostname):7077 --class ServerApp target/scala-2.11/akka-sample-app_2.11-1.0.jar
如果出现java.lang.NoClassDefFoundError错误，
请参照Spark集群 + Akka + Kafka + Scala 开发(1) : 配置开发环境，
确保akka的包在Spark中设置好了。
注：可以使用Ctrl+C来中断这个Server应用。
启动Akka Client应用
新启动一个终端，运行：
java -classpath ./target/scala-2.11/akka-sample-app_2.11-1.0.jar:$AKKA_HOME/lib/akka/*:$SCALA_HOME/lib/* ClientApp
# or
# $SPARK_HOME/bin/spark-submit --master spark://$(hostname):7077 --class ClientApp target/scala-2.11/akka-sample-app_2.11-1.0.jar
然后：看看Server应用是否开始处理了。
总结
Server应用需要Spark的技术，因此，是在Spark环境中运行。
Clinet应用，可以是一个普通的Java应用。
下面请看
至此，我们已经写好了一个spark集群+akka+scala的应用。下一步请看：
Spark集群 + Akka + Kafka + Scala 开发(4) : 开发一个Kafka + Spark的应用
参照
|