使用Python 3.x Socket UDP广播消息（测试大数据流式处理）

Myth丶恋晨 2022-11-06 05:47 67阅读 0赞

使用Python Socket UDP广播消息（测试大数据流式处理）

以下代码基于`Python 3.8.x`；在Window 10环境下测试无误。

# Server #

发送广播消息；

from socket import *
    
    SERV = socket(AF_INET, SOCK_STREAM)
    HOST = '127.0.0.1'
    
    # port
    p = input('set port(default 9999):')
    PORT = int(p) if p else 9999
    
    SERV.bind((HOST, PORT))
    SERV.listen(5)
    
    print('server startup, port: %d ..' % PORT)
    
    while True:
        print('waiting ..')
        sock, addr = SERV.accept()
        print('[%s:%d]: ready ..' % (addr[0], addr[1]))
        try:
            while True:
                data = input('[%s:%d]: ' % (addr[0], addr[1]))
                sock.send((data + '\n').encode('utf8'))
        except:
            print('disconnected ..')

注意：如果是Java客户端，一定要带上`\n`这个标记。

# Server（可指定端口，同时启动多个端口） #

from socket import *
    
    SERV = socket(AF_INET, SOCK_STREAM)
    HOST = '127.0.0.1'
    
    # port
    p = input('set port(default 9999):')
    PORT = int(p) if p else 9999
    
    SERV.bind((HOST, PORT))
    SERV.listen(5)
    
    print('server startup, port: %d ..' % PORT)
    
    while True:
        print('waiting ..')
        sock, addr = SERV.accept()
        print('[%s:%d]: ready ..' % (addr[0], addr[1]))
        try:
            while True:
                data = input('[%s:%d]: ' % (addr[0], addr[1]))
                sock.send((data + '\n').encode('utf8'))
        except:
            print('disconnected ..')

# Client（非必须，测试使用） #

用于接收消息；

实际场景为`Flink`或者`Spark Streaming`接收数据，最优方案为MQ，但测试环境部署较为麻烦，所以用Socket替代。

from socket import *
    
    HOST = '127.0.0.1'
    PORT = 9999
    
    sock = socket(AF_INET, SOCK_DGRAM)
    sock.bind((HOST, PORT))
    
    while True:
        try:
            data = sock.recv(1024)
            print(data.decode('utf8'))
        except Exception as e:
            print(e)

发表评论取消回复

表情：

评论列表（有 0 条评论，67人围观）

还没有评论，来说两句吧...

相关阅读

相关大数据——数据流式处理

一、概念大数据中包含两种处理方式：流处理和批处理。 * **流处理：**即流式处理。流式处理假设数据的潜在价值是数据的新鲜度，需要尽快处理得到结果。在这种方式...

爱被打了一巴掌/ 2024年04月17日 17:11/ 0 赞/ 124 阅读

相关 python socket编程UDP

Python中使用socket编程实现UDP协议需要使用socket模块中的socket函数来创建一个UDP套接字。下面是一个简单的UDP服务器示例代码： imp

喜欢ヅ旅行/ 2024年03月25日 11:15/ 0 赞/ 128 阅读

相关 UDP广播demo

广播UDP与单播UDP的区别就是IP地址不同，广播使用广播地址255.255.255.255，将消息发送到在同一广播网络上的每个主机。值得强调的是：本地广播信息是不会被路由器

心已赠人/ 2023年02月27日 05:54/ 0 赞/ 24 阅读

相关 python3接收web-socket消息

1.安装工具包 pip3 install websocket pip3 install websocket-client 2.代码 ws

青旅半醒/ 2023年02月20日 10:55/ 0 赞/ 42 阅读

相关使用UDP实现广播发送

目录需求描述：参考代码代码描述 ClientA代码描述： ClientB代码描述运行结果需求描述：第

小灰灰/ 2022年11月21日 01:20/ 0 赞/ 226 阅读

相关使用Python 3.x Socket UDP广播消息（测试大数据流式处理）

使用Python Socket UDP广播消息（测试大数据流式处理）以下代码基于`Python 3.8.x`；在Window 10环境下测试无误。 Server 发

Myth丶恋晨/ 2022年11月06日 05:47/ 0 赞/ 68 阅读

相关 c#和UDP SOCKET广播

server: Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram,P

迈不过友情╰/ 2022年09月18日 13:00/ 0 赞/ 262 阅读

相关 UDP局域网内广播消息

TCP/IP是一个协议族。TCP、UDP都是其中的组成部分，IP位于它们之下。

叁歲伎倆/ 2022年06月15日 03:59/ 0 赞/ 528 阅读

相关 c++ 使用UDP协议实现广播

文章参考： Windows:[https://blog.csdn.net/great3779/article/details/5699986][https_blog.csd

短命女/ 2022年04月23日 06:36/ 0 赞/ 427 阅读

相关 Python3.X 模块 socket 实训

Python3.X 模块 socket 实训前言网络上的两个程序通过一个双向的通信连接实现数据的交换，这个连接的一端称为一个socket。建立网络通信连接至

男娘i/ 2022年04月05日 09:12/ 0 赞/ 304 阅读