Python与Java间Socket通信实例代码

Python与Java间Socket通信实例代码

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.prihttp://ntln("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 (Ehttp://xception 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()

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。