Introduction à la façon d'implémenter une communication socket simple à l'aide de python

Cet article présente principalement la méthode d'implémentation d'une communication socket simple dans python, et analyse les techniques d'implémentation spécifiques du serveur et du client de communication socket sous forme d'exemples. Les amis dans le besoin peuvent se référer à

.

L'exemple de cet article décrit comment python implémente une communication socket simple. Partagez-le avec tout le monde pour votre référence, les détails sont les suivants :

Je viens de commencer à entrer en contact avec python et j'ai implémenté un programme helloworld --- une démonstration de communication socket sur le protocole UDP.

Tout d'abord, le côté serveur est implémenté comme suit :

import socket, traceback
host = '' # Bind to all interfaces 
port = 51500
# Step1: 创建socket对象
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# Step2: 设置socket选项(可选)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
# Step3: 绑定到某一个端口
s.bind((host, port))
# Step4: 监听该端口上的连接
while 1:
  try:
    message, address = s.recvfrom(8192)
    print "Got data from ", address
    s.sendto("Data is received succeefully.", address)
  except (KeyboardInterrupt, SystemExit):
    print "raise"
    raise
  except :
    print "traceback"
    traceback.print_exc()

Parmi eux, l'hôte est défini sur vide, ce qui signifie qu'il peut être lié à toutes les Interface et adresses, quel que soit le client qui fait la demande, tant qu'il est lié au même port, le serveur peut surveiller la demande.

Dans une connexion TCP, pour surveiller les requêtes des clients, vous devez utiliser listfr ou accepterfonction, et disposer d'une socket dédiée et d'une connexion à distance.

Ensuite, faites en sorte que notre client implémente  :

import socket, sys
# Step1: 输入host和port信息
host = raw_input('please input host name: ')
textport = raw_input('please input textport: ')
# Step2: 创建socket对象
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
try:
  port = int(textport)
except ValueError:
  port = socket.getservbyname(textport, 'udp')
# Step3: 打开socket连接  
s.connect((host, port))
# Step4: 发送数据
print "Enter data to transmit: "
data = sys.stdin.readline().strip()
s.sendall(data)
# Step5: 接收服务器发过来的数据
print "Looking for replies; press Ctrl-C or Ctrl-Break to stop"
while 1:
  buf = s.recv(2048)
  if not len(buf):
    break
  sys.stdout.write(buf)

Cet exemple est si simple qu'il peut être implémenté comme La version en langage C est quasiment la même. Il semble que tant que l'on comprend la programmation socket, l'implémentation dans différents langages sera presque la même.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!