统一消息系统

import org.apache.spark.SparkConf;

import org.apache.spark.streaming.Durations;

import org.apache.spark.streaming.api.java.JavaDStream;

import org.apache.spark.streaming.api.java.JavaStreamingContext;

public class MessageProcessor {

public static void main(String[] args) {

SparkConf conf = new SparkConf().setAppName("MessageProcessor").setMaster("local[*]");

JavaStreamingContext jssc = new JavaStreamingContext(conf, Durations.seconds(1));

JavaDStream messages = jssc.socketTextStream("localhost", 9999);

messages.print();

jssc.start();

jssc.awaitTermination();

}

}

]]>