Http服务传输图片的Python实现

#!/usr/bin/python
# -*-coding=utf-8 -*-

import sys
import traceback
from StringIO import StringIO

import requests
import tornado
import tornado.ioloop
import tornado.web
from tornado.escape import json_encode
from PIL import Image

reload(sys)
sys.setdefaultencoding('utf8')


class Handler(tornado.web.RequestHandler):

    def post(self):
        result = {}
        image_url = self.get_argument("image_url", default="")
        print image_url
        if not image_url:
            result["msg"] = "no image url"
        else:
            result["msg"] = self.process(image_url)
        self.write(json_encode(result))

    def process(self, image_url):
        """
        根据image_url获取图片进行处理

        :param image_url: 图片url
        """
        try:
            response = requests.get(image_url)
            if response.status_code == requests.codes.ok:
                obj = Image.open(StringIO(response.content))
                # TODO 根据obj进行相应的操作
                return "ok"
            else:
                return "get image failed."
        except Exception as e:
            print traceback.format_exc()
            return str(e)

class ImageServer(object):

    def __init__(self, port):
        self.port = port

    def process(self):
        app = tornado.web.Application([(r"/image?", Handler)], )
        app.listen(self.port)
        tornado.ioloop.IOLoop.current().start()

if __name__ == "__main__":
    server_port = "6060"
    server = ImageServer(server_port)
    print "begin server"
    server.process()

#!/usr/bin/python
# -*-coding=utf-8 -*-

import json
import urllib
import urllib2


def post(server_url, params):
    data = urllib.urlencode(params)
    request = urllib2.Request(server_url, data)
    return json.loads(urllib2.urlopen(request, timeout=10).read())


if __name__ == "__main__":
    # 图片的URL
    image_url = "https://ss0.bdstatic.com/70cFvHSh_Q1YnxGkpoWK1HF6hhy/it/u=2637851855,2992656155&fm=200&gp=0.jpg"
    # http服务的URL
    url = "http://10.10.20.20:6060/image?"
    print post(url, {"image_url": image_url})

# 其他部分参考上文URL服务的搭建方式
    def post(self):
        result = {}
        content = self.get_argument("content", default=None)
        if content is None:
            result["msg"] = "no image content"
        else:
            result["msg"] = self.content_process(content)
        self.write(json_encode(result))

    def content_process(self, image_content):
        """
        根据image_content进行相应操作

        :param image_content: 图片内容
        """
        try:
            content = pickle.loads(image_content)
            image = Image.open(StringIO(content))
            print image
            #TODO 根据image进行相应操作
            return "ok"
        except Exception as e:
            print traceback.format_exc()
            return str(e)

#!/usr/bin/python
# -*-coding=utf-8 -*-

import json
import urllib
import urllib2
import requests
import pickle


def post(server_url, params):
    data = urllib.urlencode(params)
    request = urllib2.Request(server_url, data)
    return json.loads(urllib2.urlopen(request, timeout=10).read())


def remote_image(server_url, image_url):
    """
    网络图片处理

    :param server_url: 服务器端HTTP服务URL
    :param image_url: 图片URL
    """
    content = requests.get(image_url)
    params = {"content": content}
    print post(server_url, params)


def local_image(server_url, image_path):
    """
    本地图片处理

    :param server_url: 服务器端HTTP服务URL
    :param image_path: 图片本地地址
    """
    r_file = open(image_path, "rb")
    content = pickle.dumps(r_file.read())
    params = {"content": content}
    print post(server_url, params)


if __name__ == "__main__":
    url = "http://localhost:6060/image?"

    # local image
    file_path = "D:\\log\\fastText.PNG"
    local_image(url, file_path)

    # remote image
    remote_url = "https://ss0.bdstatic.com/70cFvHSh_Q1YnxGkpoWK1HF6hhy/it/u=2637851855,2992656155&fm=200&gp=0.jpg"
    remote_image(url, remote_url)