day22 迈向大神 socket模块

网络编程

由于不同机器上的程序要通讯，才产生网络

c/s

B/S 手机端不适合

*统一入口

bs 和cs b/s 是c/s 架构一种

学完前端

广播和单播是发送mac 地址 arp 协议

广域网路由器

5000w 都恢复广播风暴

网关路由器网关

# arp协议 : 通过IP地址获取某一台机器的mac地址
# 子网掩码# 子网掩码 和 ip地址进行 按位 与 运算 就能得出一个机器所在的网段# 网关地址 : 整个局域网中的机器能沟通过网关ip与外界通信# 网段 : 子网掩码 和 ip地址进行 按位 与 运算IP代表 你找到了电脑# 端口 : 0-65535   #端口  找到的程式在计算机上每一个需要网络通信的程序，都会开一个端口在同一时间只会有一个程式占用一个端口不可能在同一时间  有2个程式  占用同一个端口《《《《《《《《《《《通过端口找程式# 8000-酷狗音乐  22-ssh  3306-mysql# python 网络应用  8000# ip地址+端口号 : 在全网找到唯一的一台机器+唯一的应用# 我们选择端口 : 8000之后# tcp协议# 全双工的通信协议  可靠的# 一旦连接建立起来,那么连接两端的机器能够随意互相通信# 面向连接的通信方式# 数据安全不容易丢失# 建立连接的 三次握手 ******# 断开连接的 四次挥手 ******    打电话udp  快    发短信自己努力  自己去想   127.0.0.1   本地回环地址已注册公网IP

全世界通用传输层选择通信协议

网络层 ip 协议

数据链路层 mac 地址 arp 协议

数据链路网桥网关以太网交换器

物理层集线器双绞线中继器

#socket 抽象层

是一个中间接口尼操作网络接口

是一个模块套接字

给予文件和网络

AF_INET 给予网络类型的套接字

写两个文件

socket
server
import socket
sk=socket.socket() #买手机
#避免服务器重启报错
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
#sk.bind('ip','port')   #绑定手机
sk.bind(('127.0.0.1',8081))   #绑定手机
sk.listen()  #等待有人打电话
conn,addr=sk.accept()    #接听电话  conn，addr   对面的地址ret=conn.recv(1024)   #听别人说话
print(ret)
conn.send(b'hello')      #和别人说话
conn.close()   #挂电话
sk.close()   #关手机client
##》》》4
import socket
sk=socket.socket() #买手机
sk.connect(('127.0.0.1',8081))   #拨别人号
sk.send(b'hi')
ret=sk.recv(1024)
print(ret)
sk.close()

改进版

#server
import socket
sk=socket.socket() #买手机
#避免服务器重启报错
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
#sk.bind('ip','port')   #绑定手机
sk.bind(('127.0.0.1',8081))   #绑定手机
sk.listen()  #等待有人打电话
conn,addr=sk.accept()    #接听电话  conn，addr   对面的地址
while 1:ret=conn.recv(1024)   #听别人说话print(ret)conn.send(b'hello')      #和别人说话ret=conn.recv(1024)print(ret.decode('utf-8'))conn.send(bytes("格拉条".encode('utf-8')))
conn.close()   #挂电话
sk.close()   #关手机##有收必有发    收发必相等      send --- recv##client
import socket
sk=socket.socket() #买手机
sk.connect(('127.0.0.1',8081))   #拨别人号while 1:sk.send(b'hi')ret = sk.recv(1024)print(ret)sk.send(bytes("中午吃什么？".encode('utf-8')))ret = sk.recv(1024)print(ret.decode('utf-8'))
sk.close()

循环聊天

import socket
sk=socket.socket() #买手机
#避免服务器重启报错
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
#sk.bind('ip','port')   #绑定手机
sk.bind(('127.0.0.1',8081))   #绑定手机
sk.listen()  #等待有人打电话
conn,addr=sk.accept()    #接听电话  conn，addr   对面的地址
while 1:ret=conn.recv(1024).decode("utf-8")if ret=='bye':breakprint(ret)info=input('>>>')conn.send(bytes(info,encoding='utf-8'))
conn.close()   #挂电话
sk.close()   #关手机##有收必有发    收发必相等      send --- recv##clientimport socket
sk=socket.socket() #买手机
sk.connect(('127.0.0.1',8081))   #拨别人号while 1:info=input(">>>")sk.send(bytes(info,encoding='utf-8'))ret = sk.recv(1024).decode("utf-8")print(ret)if ret=='bye':sk.send(b'bye')break# sk.send(b'hi')# ret = sk.recv(1024)# print(ret)# sk.send(bytes("中午吃什么？".encode('utf-8')))# ret = sk.recv(1024)# print(ret.decode('utf-8'))
sk.close()

长连接不能同时和2个人聊天

udp

import socket
sk=socket.socket(type=socket.SOCK_DGRAM)#数据豹纹的
sk.bind(('127.0.0.1',8082))#基于UDP
msg,addr=sk.recvfrom(1024)
print(msg.decode('utf-8'))
sk.sendto(b"bye",addr)
sk.close()
#不需要监听 也不需要建立连接
#在启动服务之后只能被动的等待客户端发送消息过来取
#客户端发送消息的同时 还会自带地址信息
#消息回复的时候 不仅需要发送信息  还需需要把对方的地址加上#client
import socket
sk=socket.socket(type=socket.SOCK_DGRAM)
ip_port=('127.0.0.1',8082)sk.sendto(b'hello',ip_port)
ret,addr=sk.recvfrom(1024)
print(ret.decode('utf-8'))
sk.close()

完善性质

import socket
sk=socket.socket(type=socket.SOCK_DGRAM)#数据豹纹的
sk.bind(('127.0.0.1',8083))#基于UDP
while 1:msg,addr=sk.recvfrom(1024)print(msg.decode('utf-8'))info = input("1>>>").encode('utf-8')sk.sendto("1<<".encode('utf-8')+info,addr)sk.close()
#聊一下午import socket
sk=socket.socket(type=socket.SOCK_DGRAM)
ip_port=('127.0.0.1',8083)
while 1:info=input("2>>")info=('\033[34m 大哥的消息：%s \033[0m'%info).encode('utf-8')sk.sendto(info, ip_port)#   sk.sendto("2<<".encode('utf-8')+info,ip_port)ret,addr=sk.recvfrom(1024)print(ret.decode('utf-8'))
sk.close()执行操作系统的命令
import subprocess   #可以分别拿到信息        os.popen()
res=subprocess.Popen("ipconfig",shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)  #放到管道里面
a=res.stdout.read().decode('gbk')
print(a)

基于udp 的时间同步

# 需求# 写一个时间同步的服务器# 服务端接收请求# 按照client端发送的时间格式,将服务器时间转换成对应格式# 发送给客户端
import time
import socketsk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind(('127.0.0.1',9000))
while True:msg,addr = sk.recvfrom(1024)# msg 客户端发送给server端的时间格式 "%Y-%m-%d %H:%M-%S"time_format = msg.decode('utf-8')time_str = time.strftime(time_format)sk.sendto(time_str.encode('utf-8'),addr)
sk.close()

#client

# client端每隔一段时间发送请求到服务端
# 发送时间的格式
import time
import socket
sk = socket.socket(type = socket.SOCK_DGRAM)
sk.sendto('%Y-%m-%d %H:%M:%S'.encode('utf-8'),('127.0.0.1',9000))
msg,addr = sk.recvfrom(1024)
print(msg.decode('utf-8'))
sk.close()# 方式一
# 操作系统的定时任务 + python代码的形式
# 方式二
# while True + time.sleep的形式

基于tcp 远程执行命名

#service 下发命令
import socket
sk=socket.socket()
sk.bind(('127.0.0.1',8091))
sk.listen()conn,addr=sk.accept()
conn.send(b'dir')
ret=conn.recv(1024).decode('utf-8')
print(ret)
conn.close()
sk.close()#在client  端接收命令并执行
import socket
import subprocess   #可以分别拿到信息
sk=socket.socket()
sk.connect(('127.0.0.1',8091))
cmd=sk.recv(1024).decode('gbk')res=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)  #放到管道里面
a="luxun"+(res.stdout.read()).decode('gbk')
sk.send(a.encode('utf-8'))
sk.close()#执行自定义代码区快
import socket
import subprocess   #可以分别拿到信息
sk=socket.socket()
sk.connect(('127.0.0.1',8091))
while 1:cmd=sk.recv(1024).decode('gbk')res=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)  #放到管道里面a="luxun"+(res.stdout.read()).decode('gbk')sk.send(a.encode('utf-8'))
sk.close()#service 下发命令
import socket
sk=socket.socket()
sk.bind(('127.0.0.1',8091))
sk.listen()
conn,addr=sk.accept()
while 1:cmd=input("cmd:")conn.send(cmd.encode("utf-8"))ret=conn.recv(1024).decode('utf-8')print(ret)
conn.close()
sk.close()

命令没接收完。或者接受多了黏包现象

基于UDP的远程控制命令

import socket
sk=socket.socket(type=socket.SOCK_DGRAM)#数据豹纹的
sk.bind(('127.0.0.1',8083))
msg,addr=sk.recvfrom(10240)
while True:cmd=input("cmd:")sk.sendto(cmd.encode("utf-8"),addr)msg,addr=sk.recvfrom(10240)print(msg.decode("utf-8"))sk.close()#
import socket
import subprocess
sk=socket.socket(type=socket.SOCK_DGRAM)#数据豹纹的
addr=('127.0.0.1',8083)
sk.sendto("chile".encode('utf-8'),addr)
while 1:cmd,addr=sk.recvfrom(10240)res = subprocess.Popen(cmd.decode('gbk'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)  # 放到管道里面a = "luxun" + (res.stdout.read()).decode('gbk')sk.sendto(a.encode('utf-8'),addr)
sk.close()
#udp   不会黏包  ，  不可靠tcp拆包机制    分发算法    算法优化

day22 迈向大神 socket模块相关推荐

迈向大神 day17 包的引用与异常
序列化数据类型转化成字符串的过程为了方便存储和网络传输 json 包的引入把解决一类问题的模块放在同一个文件夹里-包 init 才是包 i=[] l.append(open("ww&q ...
python大神写的代码_初学Python，只会写简单的代码。手头有份Python代码，但是调用C模块生成的.pxd和.pyx文件，运行过程总报错，希望大神指点，调试前该做哪些工作呢？...
报错内容如下: Traceback (most recent call last): File "E:\Python27\setup.py", line 16, in from s ...
python导入pyx文件_初学Python，只会写简单的代码。手头有份Python代码，但是调用C模块生成的.pxd和.pyx文件，运行过程总报错，希望大神指点，调试前该做哪些工作呢？...
报错内容如下: Traceback (most recent call last): File "E:\Python27\setup.py", line 16, in from s ...
求大神赐教Maven中子模块之间无法建立依赖关系问题
1.pom文件坐标写入后,提示Missing artifact com.ihrm:ihrm_common:jar:1.0-SNAPSHOT 求大神赐教...
python大神教程_大神python教程415集全套，拿走不谢
大神的教程由北京尚学堂高淇老师亲自录制,2019Python自学教程全新升级为<Python+数据分析+机器学习>能力逐级提升,打造技能更全面的全栈工程师. Python作为一种编程语言 ...
通往大神之路，百度Java面试题前200页。
转载自通往大神之路,百度Java面试题前200页. 基本概念操作系统中 heap 和 stack 的区别什么是基于注解的切面实现什么是对象/关系映射集成模块什么是 Java 的反射机制 ...
1024对话内核大神谢宝友
我看了CSDN的采访,感觉比较官方,不知道是不是编辑的原因把一些内容给隐藏了,所以我还是想完整的内容放出来给大家看看,这些问题,可能是很多后辈程序员非常关心的. 今天是1024节,这个数字对于写在电脑 ...
怼完Sophia怼深度学习！细数完大神Yann LeCun 这些年怼过的N件事，原来顶级高手是这样怼人的...
图片来源:PCmag.com 十多个小时前,深度学习大神Yann LeCun语出惊人,他宣布放弃"深度学习"这个词.因为媒体对这个词的炒作言过其实,混淆了大家真正的工作,而&quo ...
删库跑路大神「后悔」了？我只不过犯了大家都会犯的编程错误！
视学算法报道编辑:好困袁榭 [新智元导读]在开源程序界惹出「删库跑路」大新闻的开发者Marak Squires,最近发声:「人无完人,编程错误而已,GitHub你就不用再封我号了嘛!」 2 ...

day22 迈向大神 socket模块

day22 迈向大神 socket模块相关推荐

最新文章

热门文章