写一个动态DNS的小程序！

wan8832

新手初学python，基本上是一边看手册，一边摸索着做的！

先说一下环境：

         python2.7+MySQLdb+bind9  (FreeBSD 7.3,只会用这个系统，之前在写这个东东之前曾经在VMware和真实环境下安装了Gentoo,不太熟练，所以放弃)
原理：
         客户端登陆进守护进程，每5秒，SOCKET把IP地址==>服务端， 服务端接收IP地址后，根据用户的ID查询ip表中是否有此用户，没有则插入新IP地址，有则更新最新的IP地址，最后bind reload（我用的是bind-mysqldb，所以不用reload）

      目前只实现了linux下的client，win下的有空再搞（只会VB{:2_169:} 不知道能不能实现），server端还待完善的地方有,daemon，demo.conf，thread，log还有多记录（A，MX，TXT，CNAME，NS）

以下是Server.py

1. #!/usr/local/env python
   
2. import os, sys, string
   
3. import socket
   
4. import MySQLdb
   
5. 
   
6. sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
   
7. sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
   
8. sock.bind(("192.168.1.251",873))    #端口和地址
   
9. sock.listen(5)
   
10. while True:
    
11.         connection,address = sock.accept()
    
12.         print 'Server connected by', address
    
13.         while True:
    
14.             buf = connection.recv(1024)
    
15.             user = buf.split('/')
    
16.             username = user[0]
    
17.             if buf:
    
18.                 conn=MySQLdb.connect(host='localhost',user='root',passwd='pass',db='ddns')     #联接数据库
    
19.                 cursor = conn.cursor()
    
20.                 count = cursor.execute('select id,username,passwd from user where username=username')
    
21.                 result = cursor.fetchone();
    
22.                 if result[2] != user[1]:
    
23.                         connection.send('Your password or username is error.')
    
24.                         break
    
25.                 else:
    
26.                         conn=MySQLdb.connect(host='localhost',user='root',passwd='pass',db='ddns')
    
27.                         cursor = conn.cursor()
    
28.                         count = cursor.execute("select * from ip where uid=%s",result[0])
    
29.                         ip = cursor.fetchone();
    
30.                         if ip[1] == result[0]:
    
31.                                 new_address = [address[0],ip[2]]
    
32.                                 conn.select_db('ddns');
    
33.                                 cursor.execute("update ip set ip_address=%s where id=%s",new_address)
    
34.                                 cursor.close();
    
35.                                 conn.close();
    
36.                         else:
    
37.                                 ip_address = [address[0],result[0],int()]
    
38.                                 conn=MySQLdb.connect(host='localhost',user='root',passwd='pass',db='ddns')
    
39.                                 cursor = conn.cursor()
    
40.                                 conn.select_db('ddns');
    
41.                                 cursor.execute("insert into ip values(%s,%s,%s)",ip_address)
    
42.                                 ip_address=[]
    
43.                                 connection.send('Hello ' + user[0] +'! Your doamin is online.')
    
44.                                 cursor.close();
    
45.                                 conn.close();
    
46.             else: break
    
47.             connection.send('Hello ' + user[0] +'! Your doamin is online.')
    
48.         connection.close()
    
49. sock.close()
    

复制代码

Client.py

1. import sys, os, string
   
2. import socket
   
3. 
   
4. if len(sys.argv) < 3:
   
5.     print 'sage: %s [username] [password]'% sys.argv[0]
   
6.     sys.exit(1)
   
7. import time
   
8. while True:
   
9.         v_account = sys.argv[1]
   
10.         sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
11.         sock.connect (('192。168。1。251', 873))
    
12.         sock.send(sys.argv[1]+'/'+sys.argv[2])
    
13. #      print sock.recv(1024)
    
14.         info = sock.recv(1024)
    
15.         sock.close()
    
16.         time.sleep(5)

复制代码

范例：
# python Client.py [username] [password] &


后记：
    听人说socket的效率，还有python的线程问题，现在这两项还没有深入研究，还请有研究的童鞋多多支持我，另外我在考虑一个问题，能不能在client上开一个子程序来监听客户端IP地址的变化，如果有变化就更新到Server，这样比我现在每5秒发送一次客户端IP地址是否来得更有效率？欢迎大家给我思路！