PySpark编程实现使用Spark Streaming从TCP套接字（Socket）接收数据流（整数数字，以空格分隔），对接收到的每一行数据的前2个数字（整数）求和并将结果打印出来。 展示运行实例界面

在PySpark中，你可以使用`StreamListener`和`DStream` API来实现实时处理来自TCP套接字的数据流。以下是步骤概述：

首先，你需要导入必要的库并创建一个`StreamingContext`:

from pyspark.streaming import StreamingContext
from pyspark.sql import SparkSession

接着，设置`SparkSession`，然后创建一个`StreamingContext`实例，通常设置一个合理的滑动窗口时间（如1秒）:

spark = SparkSession.builder.appName("TcpSocketStreamExample").getOrCreate()
ssc = StreamingContext(spark, seconds=1)

然后，创建一个`Receiver`来接收TCP数据流。在这里，我们使用`SocketTextStream`函数：

socket_stream = ssc.socketTextStream('localhost', 9999) # 指定服务器地址和端口

接下来，对接收到的数据进行操作。我们需要先将每个字符串分割成整数列表，再取前两个数字求和。这需要创建一个匿名函数（lambda表达式）来完成：

def process_line(line):
    nums = line.split()  # 分割数据
    return sum([int(num) for num in nums[:2]])  # 取前两个数并求和

# 将数据转换为数值型DStream，并应用map函数处理每一条数据
numbers = socket_stream.map(lambda x: process_line(x))

最后，定义一个处理完数据后的动作（action），比如打印出结果：

numbers.foreachRDD(lambda rdd: rdd.collect())  # 打印每个批次的求和结果

现在可以启动`StreamingContext`：

ssc.start()  # 开始接收数据
ssc.awaitTermination()  # 等待直到流处理结束

运行实例界面不会像命令行那样直接显示，而是会打印控制台信息，显示每次数据批次的求和结果。