python和java相互通信_Python与Java间Socket通信

之前做过一款Java的通讯工具,有发消息发文件等基本功能.可大家也都知道Java写的界面无论是AWT或Swing,那简直不是人看的,对于我们这些开发人员还好,如果是Release出去给用户看,那必须被鄙视到底.用C&＃43;&＃43;的话,写的代码也是非常多的(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 &＃61; new ServerSocket(8086);

new Thread(this).start();

}

&＃64;Override

public void run() {

int i &＃61; 0;

System.out.println("server startup.");

while (true) {

try {

Socket s &＃61; ss.accept();

// 每个客户端一个处理线程

new Handler(s, i).start();

i&＃43;&＃43;;

} 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 &＃61; s;

this.id &＃61; id;

}

&＃64;Override

public void run() {

System.out.println("in handling..");

FileOutputStream fos &＃61; null;

try {

InputStream is &＃61; s.getInputStream();

BufferedReader in &＃61; new BufferedReader(new InputStreamReader(is));

// 从客户端读取发送过来的文件名

String filename &＃61; in.readLine();

System.out.println("read line " &＃43; id &＃43; " :" &＃43; filename);

File file &＃61; new File(filename);

int len &＃61; 0;

int BUFSIZE &＃61; 4*1024;

byte[] by &＃61; new byte[BUFSIZE * 1024];

fos &＃61; new FileOutputStream(file);

while ((len &＃61; is.read(by, 0, BUFSIZE)) !&＃61; -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&＃61;utf-8

import time

import threading

import socket

import os

class Client():

def __init__(self):

address &＃61; (&＃39;127.0.0.1&＃39;, 8086)

s &＃61; socket.socket(socket.AF_INET, socket.SOCK_STREAM)

s.connect(address)

fn &＃61; &＃39;test.zip&＃39;

ff &＃61; os.path.normcase(fn)

try:

f &＃61; open(fn, &＃39;rb&＃39;)

sendFile &＃61; SendFile(s,f)

sendFile.start()

print &＃39;start to send file.&＃39;

except IOError:

print &＃39;open err&＃39;

class SendFile(threading.Thread):

def __init__(self, sock, file):

threading.Thread.__init__(self)

self.file &＃61; file

self.sock &＃61; sock

def run(self):

print self.file

BUFSIZE &＃61; 1024

count &＃61; 0

name &＃61; self.file.name&＃43;&＃39;\r&＃39;

# 前1k字节是为了给服务端发送文件名 一定要加上&＃39;\r&＃39;,不然服务端就不能readline了

for i in range(1, BUFSIZE - len(self.filename) -1):

name &＃43;&＃61; &＃39;?&＃39;

print name

self.sock.send(name)

while True:

print BUFSIZE

fdata &＃61; self.file.read(BUFSIZE)

if not fdata:

print &＃39;no data.&＃39;

break

self.sock.send(fdata)

count &＃43;&＃61; 1

if len(fdata) !&＃61; BUFSIZE:

print &＃39;count:&＃39;&＃43;str(count)

print len(fdata)

nRead &＃61; len(fdata)

print &＃39;send file finished.&＃39;

self.file.close()

self.sock.close()

print &＃39;close socket&＃39;

c &＃61; Client()