socket 编程

import socket
import glob
import logging
import logging.handlers
import telnetlib
import time

###############################################
#### LOGGING CLASS SETTINGS (py25+, py30+) ####
###############################################

Sus = 'succesfully'
tn = telnetlib.Telnet('localhost','9999')
print '...telnet pass'
time.sleep(1)
tn.write ('xxx')
tn.read_until(Sus )
tn.write ('quit\n')
print '...quit\n'

#f1 = logging.Formatter(fmt='%(levelname)s:%(name)s: %(message)s '
#	'(%(asctime)s; %(filename)s:%(lineno)d)',
#	datefmt="%Y-%m-%d %H:%M:%S")

handlers = [
    logging.handlers.RotatingFileHandler('rotatedSyslog.log', maxBytes=10000000, backupCount=2),  #file_handler
    logging.StreamHandler()  #console_handler
]
syslog_logger = logging.getLogger()
syslog_logger.setLevel(logging.DEBUG)

for h1 in handlers:
#	h1.setFormatter(f1)
	h1.setLevel(logging.DEBUG)
	syslog_logger.addHandler(h1)
	
##############################
#### END LOGGING SETTINGS ####
##############################


s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind(('', 8888))
while True:
	data, addr = s.recvfrom(2048)
	data.rstrip('\x00')
	syslog_logger.debug(data)
#	print data

server

# 1
#!/usr/bin/python
# -*- coding: UTF-8 -*-

import socket               # 导入 socket 模块
 
s = socket.socket()         # 创建 socket 对象
host = socket.gethostname() # 获取本地主机名
port = 12345                # 设置端口
s.bind((host, port))        # 绑定端口
 
s.listen(5)                 # 等待客户端连接
while True:
    c,addr = s.accept()     # 建立客户端连接
    print '连接地址：', addr
    c.send('欢迎！')
    c.close()                # 关闭连接




# 2
#!/usr/bin/python
# -*- coding: UTF-8 -*-

import socket
# 建立一个服务端
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind(('localhost',6999)) #绑定要监听的端口
server.listen(5) #开始监听 表示可以使用五个链接排队
while True:# conn就是客户端链接过来而在服务端为期生成的一个链接实例
    conn,addr = server.accept() #等待链接,多个链接的时候就会出现问题,其实返回了两个值
    print(conn,addr)
    while True:
        try:
            data = conn.recv(1024)  #接收数据
            print('recive:',data.decode()) #打印接收到的数据
            conn.send(data.upper()) #然后再发送数据
        except ConnectionResetError as e:
            print('关闭了正在占线的链接！')
            break
    conn.close()

client

# 1
#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 文件名：client.py
 
import socket               # 导入 socket 模块
 
s = socket.socket()         # 创建 socket 对象
host = socket.gethostname() # 获取本地主机名
port = 12345                # 设置端口号
 
s.connect((host, port))
print s.recv(1024)
s.close()


# 2
#!/usr/bin/python
# -*- coding: UTF-8 -*-

import socket# 客户端 发送一个数据，再接收一个数据
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) #声明socket类型，同时生成链接对象
client.connect(('localhost',6999)) #建立一个链接，连接到本地的6969端口
while True:
    # addr = client.accept()
    # print '连接地址：', addr
    msg = '欢迎访问！'  #strip默认取出字符串的头尾空格
    client.send(msg.encode('utf-8'))  #发送一条信息 python3 只接收btye流
    data = client.recv(1024) #接收一个信息，并指定接收的大小 为1024字节
    print('recv:',data.decode()) #输出我接收的信息
client.close() #关闭这个链接