change ip to 127.0.0.1
This commit is contained in:
parent
a0010092ff
commit
bd417edb89
@ -1,56 +1,56 @@
|
||||
import socket
|
||||
import os
|
||||
import tqdm
|
||||
# device's IP address
|
||||
SERVER_HOST = "10.4.27.243" #(socket.gethostbyname(socket.gethostname()))
|
||||
SERVER_PORT = 5001
|
||||
# receive 4096 bytes each time
|
||||
BUFFER_SIZE = 4096
|
||||
SEPARATOR = "<SEPARATOR>"
|
||||
# create the server socket
|
||||
# TCP socket
|
||||
s = socket.socket()
|
||||
# bind the socket to our local address
|
||||
s.bind((SERVER_HOST, SERVER_PORT))
|
||||
# enabling our server to accept connections
|
||||
# 5 here is the number of unaccepted connections that
|
||||
# the system will allow before refusing new connections
|
||||
s.listen(5)
|
||||
print(f"[*] Listening as {SERVER_HOST}:{SERVER_PORT}")
|
||||
# accept connection if there is any
|
||||
client_socket, address = s.accept()
|
||||
# if below code is executed, that means the sender is connected
|
||||
print(f"[+] {address} is connected.")
|
||||
# receive the file infos
|
||||
# receive using client socket, not server socket
|
||||
received = client_socket.recv(BUFFER_SIZE).decode()
|
||||
filename, filesize = received.split(SEPARATOR)
|
||||
# remove absolute path if there is
|
||||
filename = os.path.basename(filename)
|
||||
# convert to integer
|
||||
filesize = int(filesize)
|
||||
# start receiving the file from the socket
|
||||
# and writing to the file stream
|
||||
progress = tqdm.tqdm(range(filesize), f"Receiving {filename}", unit="B", unit_scale=True, unit_divisor=1024)
|
||||
#with open(filename, "wb") as f:
|
||||
|
||||
while True:
|
||||
for _ in progress:
|
||||
# read 1024 bytes from the socket (receive)
|
||||
bytes_read = client_socket.recv(BUFFER_SIZE)
|
||||
if not bytes_read:
|
||||
# nothing is received
|
||||
# file transmitting is done take another time
|
||||
break
|
||||
# write to the file the bytes we just received
|
||||
f = open(filename, 'ab')
|
||||
f.write(bytes_read)
|
||||
print(bytes_read)
|
||||
# update the progress bar
|
||||
progress.update(len(bytes_read))
|
||||
f.close()
|
||||
|
||||
# close the client socket
|
||||
#client_socket.close()
|
||||
# close the server socket
|
||||
#s.close()
|
||||
import socket
|
||||
import os
|
||||
import tqdm
|
||||
# device's IP address
|
||||
SERVER_HOST = "127.0.0.1" #(socket.gethostbyname(socket.gethostname()))
|
||||
SERVER_PORT = 5001
|
||||
# receive 4096 bytes each time
|
||||
BUFFER_SIZE = 4096
|
||||
SEPARATOR = "<SEPARATOR>"
|
||||
# create the server socket
|
||||
# TCP socket
|
||||
s = socket.socket()
|
||||
# bind the socket to our local address
|
||||
s.bind((SERVER_HOST, SERVER_PORT))
|
||||
# enabling our server to accept connections
|
||||
# 5 here is the number of unaccepted connections that
|
||||
# the system will allow before refusing new connections
|
||||
s.listen(5)
|
||||
print(f"[*] Listening as {SERVER_HOST}:{SERVER_PORT}")
|
||||
# accept connection if there is any
|
||||
client_socket, address = s.accept()
|
||||
# if below code is executed, that means the sender is connected
|
||||
print(f"[+] {address} is connected.")
|
||||
# receive the file infos
|
||||
# receive using client socket, not server socket
|
||||
received = client_socket.recv(BUFFER_SIZE).decode()
|
||||
filename, filesize = received.split(SEPARATOR)
|
||||
# remove absolute path if there is
|
||||
filename = os.path.basename(filename)
|
||||
# convert to integer
|
||||
filesize = int(filesize)
|
||||
# start receiving the file from the socket
|
||||
# and writing to the file stream
|
||||
progress = tqdm.tqdm(range(filesize), f"Receiving {filename}", unit="B", unit_scale=True, unit_divisor=1024)
|
||||
#with open(filename, "wb") as f:
|
||||
|
||||
while True:
|
||||
for _ in progress:
|
||||
# read 1024 bytes from the socket (receive)
|
||||
bytes_read = client_socket.recv(BUFFER_SIZE)
|
||||
if not bytes_read:
|
||||
# nothing is received
|
||||
# file transmitting is done take another time
|
||||
break
|
||||
# write to the file the bytes we just received
|
||||
f = open(filename, 'ab')
|
||||
f.write(bytes_read)
|
||||
print(bytes_read)
|
||||
# update the progress bar
|
||||
progress.update(len(bytes_read))
|
||||
f.close()
|
||||
|
||||
# close the client socket
|
||||
#client_socket.close()
|
||||
# close the server socket
|
||||
#s.close()
|
||||
|
Loading…
x
Reference in New Issue
Block a user