Python与Java间Socket通信

　　之前做过一款Java的通讯工具,有发消息发文件等基本功能.可大家也都知道Java写的界面无论是AWT或Swing,那简直不是人看的,对于我们这些开发人员还好,如果是Release出去给用户看,那必须被鄙视到底.用C++的话,写的代码也是非常多的(QT这方面做得很好!),但我这里改用Python,以便到时用wxPython做界面.而且这两者跨平台也做得非常好.

　　这里只给出核心实现以及思路

　　Server(Java)接收从Clinet(Python)发送来的文件

　　JServer.java

import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class JServer implements Runnable {

	ServerSocket ss;

	public JServer() throws Exception {
		ss = new ServerSocket(8086);
		new Thread(this).start();
	}

	@Override
	public void run() {
		int i = 0;
		System.out.println("server startup.");
		while (true) {
			try {
				Socket s = ss.accept();
				// 每个客户端一个处理线程
				new Handler(s, i).start();
				i++;
			} catch (IOException e) {
				e.printStackTrace();
			}
		}

	}

	public static void main(String[] args) {
		try {
			new JServer();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}

class Handler extends Thread {
	Socket s;
	int id;

	public Handler(Socket s, int id) {
		this.s = s;
		this.id = id;
	}

	@Override
	public void run() {
		System.out.println("in handling..");

		FileOutputStream fos = null;
		try {
			InputStream is = s.getInputStream();
			BufferedReader in = new BufferedReader(new InputStreamReader(is));
			// 从客户端读取发送过来的文件名
			String filename = in.readLine();
			System.out.println("read line " + id + " :" + filename);
			File file = new File(filename);

			int len = 0;
			int BUFSIZE = 4*1024;
			byte[] by = new byte[BUFSIZE * 1024];
			fos = new FileOutputStream(file);
			while ((len = is.read(by, 0, BUFSIZE)) != -1) {
				fos.write(by, 0, len);
				fos.flush();
			}
			System.out.println("done.");
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			// 服务端就不要手贱 关了socket否则Python 会出现错误Errno 10054让客户端关掉就行啦
			try {
				fos.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

 

---

　　Python客户端

# -*- coding: utf-8 -*-
#!/usr/bin/python
#coding=utf-8
import time
import threading
import socket
import os

class Client():
	def __init__(self):
		address = ('127.0.0.1', 8086)
		s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
		s.connect(address)
		fn = 'test.zip'
		ff = os.path.normcase(fn)

		try:
			f = open(fn, 'rb')
			sendFile = SendFile(s,f)
			sendFile.start()
			print 'start to send file.'
		except IOError:
			print 'open err'


class SendFile(threading.Thread):
	def __init__(self, sock, file):
		threading.Thread.__init__(self)
		self.file = file
		self.sock = sock

	def run(self):
		print self.file
		BUFSIZE = 1024
		count = 0
		name = self.file.name+'\r'
　　　　　　　　　# 前1k字节是为了给服务端发送文件名 一定要加上'\r',不然服务端就不能readline了
		for i in range(1, BUFSIZE - len(self.filename) -1):
			name += '?'
		print name
		self.sock.send(name)
		while True:
			print BUFSIZE
			fdata = self.file.read(BUFSIZE)
			if not fdata:
				print 'no data.'
				break
			self.sock.send(fdata)
			count += 1
			if len(fdata) != BUFSIZE:
				print 'count:'+str(count)
				print len(fdata)
			nRead = len(fdata)

		print 'send file finished.'
		self.file.close()
		self.sock.close()
		print 'close socket'

c = Client()

　　

转载于:https://www.cnblogs.com/localhost/archive/2012/10/13/2722453.html