Python與Java間Socket通信
之前做過一款Java的通訊工具,有發(fā)消息發(fā)文件等基本功能.可大家也都知道Java寫的界面無論是AWT或Swing,那簡(jiǎn)直不是人看的,對(duì)于我們這些開發(fā)人員還好,如果是Release出去給用戶看,那必須被鄙視到底.用C++的話,寫的代碼也是非常多的(QT這方面做得很好!),但我這里改用Python,以便到時(shí)用wxPython做界面.而且這兩者跨平臺(tái)也做得非常好.
這里只給出核心實(shí)現(xiàn)以及思路
Server(Java)接收從Clinet(Python)發(fā)送來的文件
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();
// 每個(gè)客戶端一個(gè)處理線程
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));
// 從客戶端讀取發(fā)送過來的文件名
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 {
// 服務(wù)端就不要手賤 關(guān)了socket否則Python 會(huì)出現(xiàn)錯(cuò)誤Errno 10054讓客戶端關(guān)掉就行啦
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字節(jié)是為了給服務(wù)端發(fā)送文件名 一定要加上'\r',不然服務(wù)端就不能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()
感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫作最大的動(dòng)力，如果您喜歡我的文章，感覺我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
