Python Sixth Step: socket

import socket

tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

创建服务器套接字    s.socket()
套接字与地址绑定    s.bind()
监听连接           s.listen()
服务器无限循环
接收客户端连接      cs = s.accept()
接收到连接后进行通信循环
进行对话（接收，发送） cs.recv()   cs.send()
对话结束关闭客户端套接字 cs.close()
（可选）关闭服务器套接字或不关闭继续监听  s.close()

from socket import *
from time import ctime


HOST = ''       # 表示可以使用任何可用的地址
PORT = 21566    # 随机的一个端口号，该端口号没有被使用或系统保留
BUFSIZE = 1024  # 缓冲区大小 1KB
ADDR = (HOST, PORT)

tcp_ser_sock = socket(AF_INET, SOCK_STREAM)     # 创建 ipv4 tcp 套接字, 如果使用IPv6，则替换 AF_INET 为 AF_INET6 即可
tcp_ser_sock.bind(ADDR)     # 将套接字绑定到服务器地址
tcp_ser_sock.listen(5)      # 开启 TCP 监听器， 参数 5 代表连接被转接或拒绝前，接收连接请求的最大数

while True:     # 无限循环, 可以对这个循环进行 KeyboardInterrupt 或 EOFError 异常捕获，在 finally 中关闭服务器套接字
    print('阻塞中，等待客户端连接...')
    tcp_client_sock, addr = tcp_ser_sock.accept()   # 被动接受 TCP 客户端连接，一直等待直到连接到达
    print('已连接到地址:', addr)

    while True:     # 接收到连接，进入对话
        data = tcp_client_sock.recv(BUFSIZE)    # 接收消息
        if not data:    # 如果消息空白，意味客户端已经退出，此时跳出对话循环
            break
        tcp_client_sock.send(bytes('[%s] %s' % (ctime(), data), 'utf-8'))    # 如果接收到使用信息，将信息格式化并返回相同到数据

    tcp_client_sock.close()     # 关闭当前客户端连接

tcp_ser_sock.close()

创建客户端套接字    cs = socket()
连接服务器         cs.connect()
通信循环
对话（接收，发送)   cs.recv()   cs.send()
关闭客户端套接字    cs.close()

from socket import *


HOST = 'localhost'  # 本地服务器主机名, 如果是 IPv6 则需要把本地主机修改成它的 IPv6 地址: HOST = '::1'
PORT = 21566        # 服务器端口号，需要与服务器设置的完全相同
BUFSIZE = 1024      # 缓冲区带下 1KB
ADDR = (HOST, PORT)

tcp_client_sock = socket(AF_INET, SOCK_STREAM)  # 创建 tcp 套接字, 如果使用IPv6，则替换 AF_INET 为 AF_INET6 即可
tcp_client_sock.connect(ADDR)   # 连接到服务器

while True:     # 无限循环
    data = input('输入发送的数据: ')   # 输入数据
    if not data:    # 没有输入数据时，跳出循环
        break
    tcp_client_sock.send(bytes(data, 'utf-8'))     # 发送数据到服务器进行处理
    data = tcp_client_sock.recv(BUFSIZE)    # 接收到服务器返回到数据
    if not data:    # 服务器终止或者 recv() 方法调用失败时跳出循环
        break
    print(data.decode('utf-8'))     # 使用数据

tcp_client_sock.close()

阻塞中，等待客户端连接...
已连接到地址: ('127.0.0.1', 54736)

输入发送的数据: 2222222
[Wed Jan 10 23:32:35 2018] b'2222222'
输入发送的数据: 2323232
[Wed Jan 10 23:33:23 2018] b'2323232'
输入发送的数据: fefefef
[Wed Jan 10 23:33:25 2018] b'fefefef'
输入发送的数据: 

Process finished with exit code 0

创建服务器套接字    s = socket()
绑定服务器套接字    s.bind()
服务器无限循环     
接收或发送UDP消息     s.recvfrom()  s.sendto()
关闭服务器套接字    s.close() 

from socket import *
from time import ctime


HOST = ''
PORT = '21565'
BUFSIZE = 1024
ADDR = (HOST, PORT)

udp_service_sock = socket(AF_INET, SOCK_DGRAM)
udp_service_sock.bind(ADDR)     # UDP 是无连接到，所以绑定后，不需要开启监听器

while True:
    print('阻塞，等待消息...')     # UDP 不需要连接，只需要等待接收消息
    data, addr = udp_service_sock.recvfrom(BUFSIZE)
    udp_service_sock.sendto(bytes('[%s] %s' % (ctime(), data), 'utf-8'), addr)
    print('接收到信息，并返回信息到', addr)

udp_service_sock.close()

创建客户端套接字    cs = socket()
通信循环
对话（发送/接收）   cs.sendto() cs.recvfrom()
关闭客户端套接字    cs.close()

from socket import *


HOST = 'localhost'
PORT = 21565
BUFFSIZE = 1024
ADDR = (HOST, PORT)

udp_client_sock = socket(AF_INET, SOCK_DGRAM)

while True:
    data = input('请输入数据:')
    if not data:
        break
    udp_client_sock.sendto(bytes(data, 'utf-8'), ADDR)
    data, addr = udp_client_sock.recvfrom(BUFFSIZE)
    if not data:
        break
    print(data)

udp_client_sock.close()

与 TCP 一致

客户端连接远程主机上的 FTP 服务器
客户端输入用户名和密码（或者 'anonymous'和电子邮件地址）
客户端进行各种文件传输和信息查询操作
客户端从远程FTP服务器退出，结束传输

from ftplib import FTP


f = FTP('ftp.python.org')
f.login()
f.dir()
f.retrlines('RETR motd')
f.quit()

import ftplib
import os
import socket


HOST = 'ftp.mozilla.org'
DIR = 'pub/webtools/'
FILE = 'mozbot-LATEST.tar.gz'


def main():
    try:
        f = ftplib.FTP(HOST)    # 创建 FTP 对象, 并尝试连接到 FTP 服务器
    except (socket.error, socket.gaierror):
        print('ERROR 无法连接到 "%s"' % HOST)
        return

    print('连接到 FTP 服务器 "%s"' % HOST)

    try:
        f.login()   # 匿名登陆
    except ftplib.error_perm:
        print('ERROR 无法匿名登陆')
        f.quit()
        return

    print('匿名登陆成功')

    try:
        f.cwd(DIR)  # 转到目录
    except ftplib.error_perm:
        print('ERROR 无法切换目录到 "%s"' % DIR)
        f.quit()
        return

    print('切换目录到 "%s"' % DIR)

    try:
        local_file = open(FILE, 'wb')
        f.retrbinary('RETR %s' % FILE, local_file.write)  # 下载文件
        local_file.close()
    except ftplib.error_perm:
        print('ERROR 无法读取文件 "%s"' % FILE)
        os.unlink(FILE)     # 如果下载失败，就移除这个空文件
    else:
        print('下载文件 "%s"' % FILE)

    f.quit()


if __name__ == '__main__':
    main()

连接到服务器
登陆
发出服务请求
退出

from nntplib import NNTP


n = NNTP('your.nntp.server')
r, c, f, l, g = n.group('comp.lang.python')     # 服务器到回复，文章到数量，第一篇和最后一篇到文章ID，新闻组到名称
# 其他操作
n.quit()

连接到服务器
登陆(可选)
发出服务请求
退出

from smtplib import SMTP as smtp


s = smtp('smtp.host')
s.set_debuglevel(1)

s.sendmail('afra55@foxmail.com', ('afra@foxmail.com', '786654260@qq.com'), '''From:afra55@foxmail.com\r\nTo:afra@foxmail.com,786654260@qq.com\r\nSubject:test message\r\n\r\nAfra55\r\n.''')
s.quit()

from poplib import POP3 
p = POP3('pop.python.is.cool') 
p.user(...)
p.pass_(...)
...
p.quit()

from imaplib import IMAP4 
s = IMAP4('imap.python.is.cool') 
s.login(...) 
... 
s.close()
s.logout()

from email.mime.image import MIMEImage
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from smtplib import SMTP


def make_mpa_msg():
    """
    包含纯文本消息，和 HTML 消息，由邮件客户端显示哪个部分
    基于 Web 的 电子邮件 系统 会 显示 HTML 版本， 而 基于 命令 行的 邮件 阅读 器 只会 显示 纯 文本 版本
    :return: MIMEMultipart
    """
    email = MIMEMultipart('alternative')  # 如果不传 alternative ，则文本和 HTML 会分别作为消息中的附件发送
    text = MIMEText('Hello World!\r\n', 'plain')
    email.attach(text)  # 附加到邮件中
    html = MIMEText(
        '<html><body><h4>Hello World!</h4>'
        '</body></html>', 'html')
    email.attach(html)  # 附加到邮件中
    return email


def make_img_msg(fn):
    """
    图片消息
    :param fn: 文件名
    :return: MIMEImage
    """
    f = open(fn, 'r')
    data = f.read()
    f.close()
    email = MIMEImage(data, name=fn)
    email.add_header('Content-Disposition',
                     'attachment; filename="%s"' % fn)  # 添加 Header
    return email


def send_msg(fr, to, msg):
    """
    获取 基本 的 电子邮件 发送 信息（ 发 件 人、 收件人、 消息 正文）， 接着 传送 消息， 然后 返回 给 调用 者
    :param fr:
    :param to:
    :param msg:
    :return:
    """
    s = SMTP('localhost')
    errs = s.sendmail(fr, to, msg)
    s.quit()


if __name__ == '__main__':
    print('sending multipart alternative msg')
    msg = make_mpa_msg()
    msg['From'] = SENDER
    msg['To'] = ', '.join(RECIPS)
    msg['Subject'] = 'multipart alternative test'
    send_msg(SENDER, RECIPS, msg.as_string())

    print('sending image msg')
    msg = make_img_msg(SOME_IMG_FILE)
    msg['From'] = SENDER
    msg['To'] = ', '.join(RECIPS)
    msg['Subject'] = 'image file test'
    send_msg(SENDER, RECIPS, msg.as_string())

import email


def processMsg(entire_msg):
    body = ''
    msg = email.message_from_string(entire_msg)
    if msg.is_multipart(): 
        for part in msg.walk(): 
            if part.get_content_type() == 'text/ plain': 
                body = part.get_payload() 
                break 
            else: 
                body = msg.get_payload(decode=True) 
    else: 
        body = msg.get_payload(decode=True) 
        return body