parent
74121d0751
commit
419f743a36
@ -0,0 +1,32 @@
|
||||
import socket
|
||||
import time
|
||||
|
||||
def recv_data(sock,length):
|
||||
data=b''
|
||||
while len(data) < length:
|
||||
more = sock.recv(length - len(data))
|
||||
if not more:
|
||||
pass
|
||||
#raise EOFError('Cannot RECV execpting data')
|
||||
data += more
|
||||
return data
|
||||
|
||||
|
||||
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
|
||||
# 设置接收缓冲区大小为1024
|
||||
s.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 1024)
|
||||
|
||||
s.bind(('0.0.0.0', 9999))
|
||||
s.listen(1)
|
||||
print("Sever listening on 9999...")
|
||||
try:
|
||||
sc, addr = s.accept()
|
||||
while True:
|
||||
rcvdata = recv_data(sc,16)
|
||||
time.sleep(0.01)
|
||||
pass
|
||||
|
||||
finally:
|
||||
sc.close()
|
||||
s.close()
|
@ -0,0 +1,24 @@
|
||||
import socket
|
||||
import time
|
||||
|
||||
ip_port = ("server", 9999)
|
||||
data = "0123456789\n"*100
|
||||
|
||||
c = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
|
||||
try:
|
||||
c.connect(ip_port)
|
||||
print("Connected.")
|
||||
time.sleep(1)
|
||||
i=0
|
||||
while i<10:
|
||||
print("Send:"+data)
|
||||
c.send(data.encode())
|
||||
i=i+1
|
||||
|
||||
finally:
|
||||
print("Sent. Waiting....")
|
||||
|
||||
while True:
|
||||
time.sleep(0.001)
|
||||
|
Before Width: | Height: | Size: 9.8 KiB After Width: | Height: | Size: 20 KiB |
Loading…
Reference in new issue