Python与Java间Socket通信实例代码

Python与Java间Socket通信　　之前做过一款Java的通讯工具,有发消息发文件等基本功能.可大家

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()

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

Python与Java间Socket通信 Python与Java间Socket通信如何实现 Python Java间Socket通信