通过套接字发送字符串（python）

Question

我有两个脚本，Server.py 和 Client.py。 我有两个目标：

1. 能够一次又一次地从客户端向服务器发送数据。
2. 能够将数据从服务器发送到客户端。

这是我的 Server.py ：

import socket

serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = "192.168.1.3"
port = 8000
print (host)
print (port)
serversocket.bind((host, port))

serversocket.listen(5)
print ('server started and listening')
while 1:
    (clientsocket, address) = serversocket.accept()
    print ("connection found!")
    data = clientsocket.recv(1024).decode()
    print (data)
    r='REceieve'
    clientsocket.send(r.encode())

这是我的客户：

#! /usr/bin/python3

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host ="192.168.1.3"
port =8000
s.connect((host,port))

def ts(str):
   s.send('e'.encode()) 
   data = ''
   data = s.recv(1024).decode()
   print (data)

while 2:
   r = input('enter')
   ts(s)

s.close ()

该功能第一次工作（'e' 进入服务器，我得到返回消息），但我如何让它一遍又一遍地发生（类似于聊天应用程序）？ 问题在第一次之后开始。消息不会在第一次之后发送。 我究竟做错了什么？ 我是python新手，所以请稍微详细一点，如果可以的话，请给出整个东西的源代码。

Answer 1

import socket
from threading import *

serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = "192.168.1.3"
port = 8000
print (host)
print (port)
serversocket.bind((host, port))

class client(Thread):
    def __init__(self, socket, address):
        Thread.__init__(self)
        self.sock = socket
        self.addr = address
        self.start()

    def run(self):
        while 1:
            print('Client sent:', self.sock.recv(1024).decode())
            self.sock.send(b'Oi you sent something to me')

serversocket.listen(5)
print ('server started and listening')
while 1:
    clientsocket, address = serversocket.accept()
    client(clientsocket, address)

这是一个非常简单的设计，您可以如何解决它。 首先，您需要在进入 while 1 循环之前接受客户端（服务器端），因为在每个循环中您都接受一个新客户端，或者按照我的描述，您将客户端扔到一个单独的线程中从现在开始自己处理。

Answer 2

客户端.py

import socket

s = socket.socket()
s.connect(('127.0.0.1',12345))
while True:
    str = raw_input("S: ")
    s.send(str.encode());
    if(str == "Bye" or str == "bye"):
        break
    print "N:",s.recv(1024).decode()
s.close()

server.py

import socket

s = socket.socket()
port = 12345
s.bind(('', port))
s.listen(5)
c, addr = s.accept()
print "Socket Up and running with a connection from",addr
while True:
    rcvdData = c.recv(1024).decode()
    print "S:",rcvdData
    sendData = raw_input("N: ")
    c.send(sendData.encode())
    if(sendData == "Bye" or sendData == "bye"):
        break
c.close()

这应该是您想要的聊天应用程序的小型原型的代码。 在单独的终端中运行它们，然后只检查端口。

Answer 3

这段代码不正确。

while 1:
    (clientsocket, address) = serversocket.accept()
    print ("connection found!")
    data = clientsocket.recv(1024).decode()
    print (data)
    r='REceieve'
    clientsocket.send(r.encode())

对serversocket 上的accept() 的调用会阻塞，直到有客户端连接。当您第一次从客户端连接到服务器时，它会接受连接并接收数据。但是，当它再次进入循环时，它正在等待另一个连接并因此阻塞，因为没有其他客户端正在尝试连接。

这就是recv 只能在第一次正确工作的原因。您应该做的是找出如何处理与已接受的客户端的通信 - 也许通过创建一个新线程来处理与该客户端的通信并继续在循环中接受新客户端，以相同的方式处理它们。

提示：如果你想创建自己的聊天应用程序，你应该看看像 Twisted 这样的网络引擎。它也将帮助您更好地理解整个概念。