擅长:python、mysql、java
<p>我通过创建独立的python程序来实现这一点</p>
<pre><code># -*- coding: utf-8 -*-
import socket, string
import MySQLdb
import select
def write_message(x):
db = MySQLdb.connect(host="localhost", user="root", passwd="****", db="****", charset='utf8')
cursor = db.cursor()
sql = '''INSERT INTO test(test_c) VALUES ('%(test_c)s') '''%{"test_c":x}
cursor.execute(sql)
db.commit()
db.close()
return x
HOST = ""
PORT = 1234567
srv = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
srv.bind((HOST, PORT))
while 1:
print u"Listen to " + str(PORT)
srv.listen(1)
sock, addr = srv.accept()
while 1:
pal = sock.recv(2048)
if not pal:
break
print u"Recieved %s:%s:" % addr, pal
lap = write_message(pal)
sock.close()
</code></pre>