Python基本socket通信控制操作示例

本文实例讲述了Python基本socket通信控制操作。分享给大家供大家参考，具体如下：

python — 基本socket通信控制（控制在celie.txt文件中主机IP地址可以发送信息，并返回对应的客户端IP、时间戳、发送的信息）

客户端代码

root@72129clent:~/python/snmp# lssnmpclenit.py tab.pyroot@72129clent:~/python/snmp# cat snmpclenit.py#!/usr/bin/python# --*-- coding:utf-8 --*--import sockethost,port = '192.168.72.130',18000s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#调用IPv4协议s.connect((host,port))#连接主机与端口s.send("up")#客户端给服务器端发送数据“up”s.close()root@72129clent:~/python/snmp#

服务器短信代码：

root@kali:~/python/snmp# lscelie.txt snmpserver.py tab.py tab.pycroot@kali:~/python/snmp# cat celie.txt192.168.72.129 xuweiboroot@kali:~/python/snmp#root@kali:~/python/snmp# cat snmpserver.py#!/usr/bin/python# --*-- coding:utf-8 --*--import datetime#导入时间戳import SocketServer#读取目录下的celie.txt文件host_status = {}#新建字典，使用IP地址作为KEY值。作用是来判断每个客户端IP多久与服务器通信一次的f = open('celie.txt')#调用策略文档，在里面的ip地址就可以通过，并发送信息while True:  line = f.readline().split()  if len(line) == 0:break  print line[0]#打印第一个IP地址信息  host_status[line[0]] = []#给字典第一个设置为空，这样后面只要直接追加值就ok了f.close()class myMonitorHandler(SocketServer.BaseRequestHandler):  '''This is the Monitor server'''  def handle(self):    recv_data = self.request.recv(1024)#接收客户端数据    if self.client_address[0] in host_status.keys():#如果存在字典中的ip地址信息，就返回对应客户端发送的Ip、时间戳、信息      #self.client_address为数组('192.168.72.129', 49109)的值。只要当中的IP地址，因此取self.client_address[0]      #把host_status字典中的self.client_address[0]值即IP地址值赋值有两个值，因此新建个列表，存取两个值时间戳与接收的信息      #如：{'192.168.72.129': [(datetime.datetime(2017, 8, 20, 21, 29, 59, 415054), 'up')]}      #host_status[self.client_address[0]] = [(datetime.datetime.now(),recv_data)]      #直接把元组append进字典      host_status[self.client_address[0]].append((datetime.datetime.now(),recv_data))      print 'From %s : %s %s' %(self.client_address,datetime.datetime.now(),recv_data)#打印客户端地址、操作的时间戳值与接收的数据      #print host_status    else:#不存在字典中，则如下提示信息      print "sorry, ip %s is not in the monitor list" % self.client_address[0]    #打印出192.168.72.129 [(datetime.datetime(2017, 8, 20, 22, 1, 6, 705498), 'up')]    for t,m in host_status.items():      print t,mif __name__ == "__main__":#当自己运行时调用什么什么；当被其他程序调用时调用什么什么,如果被其他程序调用了，下面代码不执行  host,port = '',18000  server = SocketServer.ThreadingTCPServer((host,port),myMonitorHandler)#调用TCP的多线程  server.serve_forever()root@kali:~/python/snmp#