python socket发送组播数据_Python socket 如何实现广播单播切换
展开全部
import timeimport threadingimport queueimport socket# 三个线程:e5a48de588b662616964757a686964616f31333337396165# 线程1:产生递增的数字,转成字符串放到队列中# 线程2:监听端口,将产生的连接放到列表中# 线程3:从队列中取出数字,遍历连接列表,发送到所有客户端# 线程1:产生递增的数字,转成字符串放到队列中class Producer(threading.Thread):
def __init__(self, work_queue):
super().__init__() # 必须调用
self.work_queue = work_queue
def run(self):
#print("Begin produce...")
num = 1
while True:
self.work_queue.put(str(num))
num = num+1
time.sleep(1) # 暂停1秒# 线程2:监听端口,将产生的连接放到列表中class SocketServer(threading.Thread):
def __init__(self, socket_list):
super().__init__()
self.socket_list = socket_list
def run(self):
sock = socket.socket()
sock.bind(('', 9090))
sock.listen(5)
print("Start listen...")
while True:
conn, addr = sock.accept()
print("Connect by", addr)
self.socket_list.append((conn, addr))# 线程3:从队列中取出数字,遍历连接列表,发送到所有客户端class Printer(threading.Thread):
def __init__(self, work_queue, socket_list):
super().__init__() # 必须调用
self.work_queue = work_queue
self.socket_list = socket_list
def run(self):
while True:
num = self.work_queue.get() # 当队列为空时,会阻塞,直到有数据
for sock, addr in self.socket_list: # 遍历保存连接的列表
print("Send", num, "To", addr)
try:
sock.sendall(bytes(num + '\r\n', 'utf-8')) # 把字符串转换成字节数组发送
except:
print("Disconnect by", addr) # 如果连接断开,发送会失败
self.socket_list.remove((sock, addr)) # 从列表中删除断开的连接def main():
work_queue = queue.Queue()
socket_list = [] # 为了更安全可靠,从多线程访问列表时应该加锁,
# 这里做了简化,因为列表的增加删除操作基本上可以认为是线程安全的
socket_server = SocketServer(socket_list)
socket_server.daemon = True
socket_server.start()
printer = Printer(work_queue, socket_list)
printer.daemon = True # 当主线程退出时子线程也退出
printer.start()
producer = Producer(work_queue)
producer.daemon = True # 当主线程退出时子线程也退出
producer.start()
time.sleep(1) # 这里要暂停一下,否则执行下一条语句时,会因队列为空而直接返回
work_queue.join() # 主线程会停在这里,直到所有数字被get(),并且task_done(),因为没有调用task_done(),所在这里会一直阻塞,直到用户按^Cif __name__ == '__main__':
main()
python socket发送组播数据_Python socket 如何实现广播单播切换相关推荐
- python socket发送组播数据_python3通过udp实现组播数据的发送和接收操作
本文主要通过对海康摄像头进行抓包,模拟发送了udp包,并抓取摄像头返回的数据包,解析并提取相关信息. 通过抓包发现,海康摄像头发送.接收数据使用udp协议,后来比较发现,使用python模拟起来比较简 ...
- android 不能接收组播数据,但能够发送组播数据
http://blog.csdn.net/hknock/article/details/44244031 Android的Wifi,默认情况下是不接受组播的,见:http://developer.an ...
- socket(四)–组播
socket(四)–组播 文章目录 socket(四)--组播 一.简介 二.知识点 2.1 组播地址 三.关键类 3.1 java.net.MulticastSocket 3.2 java.net. ...
- java (多网卡环境下)发送组播广播(multicast/broadcast)失败问题
java发送组播或广播包并不复杂网上有很多文章,比如下面的两篇: <Java实现组播(multicast)简单例子> <Java 网络编程案例:使用 MulticastSocket ...
- wireshark抓组播数据_HCIE学习笔记--组播路由协议PIM-DM工作机制解析
拓扑 二---PIM--DM扩散 组播源发出的第一份ping包此组播域当中的哪些链路和路由器会接收到?解释对应机制与工作原理 组播路由器接口开启了PIM-DM的都会接收到组播报文. 在PIM-DM模式 ...
- python获取本地时间并向服务器发送udp报文_python3通过udp实现组播数据的发送和接收操作...
本文主要通过对海康摄像头进行抓包,模拟发送了udp包,并抓取摄像头返回的数据包,解析并提取相关信息. 通过抓包发现,海康摄像头发送.接收数据使用udp协议,后来比较发现,使用python模拟起来比较简 ...
- ios 接收 c# socket udp 组播
最近用wcf 服务 给ios和安卓做接口,做了几个ios的项目 用udp 组播 让ios多终端接收和刷新方法 做一个简单的小例子会把工程给大家下载的 c#代码:netSocketUDP.rar io ...
- windows7 python 指定源组播 10049_Python3组播通信编程实现教程(发送者+接收者)
一.说明 1.1 标准组播解释 通信分为单播.多播(即组播).广播三种方式 单播指发送者发送之后,IP数据包被路由器发往目的IP指定的唯一一台设备的通信形式,比如你现在与web服务器通信就是单播形式 ...
- 2022-10-31 网工进阶(三十三) IP组播-流量模型、组播概念、组播报文结构、组播地址与MAC、组播网络架构、组播服务模型、组播数据转发原理(RPF检查、组播分发树、组播协议介绍)
IP组播概念 流量模型 网络中存在各种各样的业务,从流量模型看一般可以将业务分为两类: 点到点业务:比如FTP,WEB业务,此类业务主要特点是不同的用户有不同的需求,比如用户A需要下载资料A,用户B需 ...
最新文章
- 如何自学python a byte to python-你是如何自学 Python 的?
- 简洁的导出 datatable到excel,不用组件
- C++笔记-远程线程注入
- 任务app源码运营版本
- 一条数据的HBase之旅,简明HBase入门教程3:适用场景
- 对NVM区的合理使用
- ceph进程启动流程
- typora 有道云笔记_有道云—目前最好用的免费笔记
- java 开源客服系统_一个开源的智能客服系统
- 刘晓震:新浪博客应用架构分享
- python海龟画五角星随机_Python turtle 绘制五角星
- 高性能PC机与服务器的真正区别
- JQuery 判断访问的浏览器是pc还是手机
- cisco将计算机配置为vlan2,思科路由器如何配置VLAN的IP
- GitLab CI/CD .gitlab-ci.yaml 关键词(三):制品artifacts,缓存cache
- 用VB开发USB接口POS打印机进行打印和弹钱箱
- Microsoft Academic Search 微软学术搜索体验
- [2021时空AI白皮书]时空人工智能:城市数字化转型的新引擎
- Matlab Tips: 高效实用的快捷命令
- 2023年,哪些行业最具发展潜力?
热门文章
- ACE的接受器(Acceptor)和连接器(Connector):连接建立模式
- ATL服务器:用 Visual C++创建的高性能的Web应用程序和XML Web 服务
- OpenCV3实现人脸识别(一)——基于OpenCV3级联分类器实现人脸检测与眼睛检测
- 三维重建学习(2):相机标定基础
- python日期格式修改年月日_Python time模块格式化中文年月日
- nacos 怎么配置 里的配置ip_Nacos-服务注册地址为内网IP的解决办法
- ASP.NET生成缩略图类C#代码
- 使用Cloud application Studio在C4C UI里创建下拉列表(dropdown list)
- do {...} while (0) 在宏定义中的作用
- python 编码文件json.loads json.dumps