Weblogというかメモ帳

import socket
from threading import Thread,Lock
import thread
import sys
 
class SocketServer(Thread,object):
 
    def __init__(self):
 
        #super class init
        Thread.__init__(self)
 
        #socket settings
        self.s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
        self.s.settimeout(1000)
        self.while_count = 0
 
        self.while_flag=True
        self.data=[]
 
         #port number options
         if "-p" in sys.argv[1:]:
            self.port = sys.argv[sys.argv.index("-p")+1]
            try :
                self.port=int(self.port)
            except :
                print "Error! Port number is integer."
                sys.exit() 
 
        #Default port number = 7777 
        else :
            self.port = 7777
 
    #Main Thread.
    def run(self):
 
        print "=" * 50
        print "Start the server program."
        print "Listening at : %s" % self.port
        print "=" * 50
        print "Pending connections..."
 
        try:
            self.s.bind(('',self.port))
            self.s.listen(10)
        except :
            print "Network error."
            print "Is the port number is already being used?"
            sys.exit()
 
        #While get recv
        while self.while_flag:
 
            self.conn,self.addr = self.s.accept()
 
            #print connect to
            if self.while_count == 0:
                print "Connected by %s " % self.addr[0]
                self.while_count=1
 
            else :
                pass
 
            try :
                self.data=self.conn.recv(1024).encode("utf-8")
                self.conn.send("OK")
 
                if self.data == "exit":
                    print "%s is closed the connection" % self.addr[0]
                    self.data="=== Withdrawal ==="
                self.conn.close()
 
            except :
                print "Failed recv."
                self.conn.close()
 
            try :
                if len(self.data) !=0:
                    print "-" * 50
                    print "%s => %s" % (self.addr[0],self.data)
                    self.conn.close()
            except :
                pass
 
            self.conn.close()
 
    #Send to argument.
    def send(self,val):
 
        try :
            self.conn.send(val+"\n")
 
        except :
            print "Error! one more please."
 
    #Thread stop method
    def stop(self):
 
        self.while_flag=False
 
        try:
            print "wait..."
            self.conn.send("Please enter a space , charcter. exsample => [bye].")
 
        except:
            print "Please enter a space , charcter or a client"
 
        self.conn.close()
        print "Connection will be closed"