大家好,又见面了,我是全栈君,祝每个程序员都可以多学几门语言。
在windows下装了个linux虚拟机,两者之间传输文件挺麻烦的.写了个简单的文件传输程序,来方便自己数据传送.
server 端:
import
java.io.BufferedReader;
import
java.io.BufferedWriter;
import
java.io.File;
import
java.io.FileOutputStream;
import
java.io.InputStream;
import
java.io.InputStreamReader;
import
java.io.OutputStreamWriter;
import
java.io.PrintWriter;
import
java.net.ServerSocket;
import
java.net.Socket;
class
CPThread
extends
Thread
{
Socket socket = null;
public CPThread(Socket socket){
this.socket = socket;
}
public void run(){
try{
InputStream in =
socket.getInputStream();
PrintWriter out =
new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socket.getOutputStream())),true);
while(true)
{
//第一个參数为命令
byte cmd[] = new byte[128];
int b = 0;
while(b<cmd.length){
b += in.read(cmd, b, cmd.length–b);
}
int ends = 0;
for(int i=0;i<cmd.length;i++){
if(cmd[i]==‘-0‘){
ends = i;
break;
}
}
String cmds = new String(cmd,0,ends);
if(“exit“.equals(cmds)){
System.exit(0);
}
else if(“cp“.equals(cmds)){
byte[] filename = new byte[256];
b = 0;
while(b<filename.length){
b += in.read(filename, b, filename.length–b);
}
ends = 0;
for(int i=0;i<filename.length;i++){
if(filename[i]==‘-0‘){
ends = i;
break;
}
}
String filenames = new String(filename,0,ends);
File fileout = new File(filenames);
if(fileout.isFile()){
throw new Exception(“file exists“+fileout.getAbsolutePath());
}
FileOutputStream fos = new FileOutputStream(fileout);
byte[] filesize = new byte[64];
b = 0;
while(b<filesize.length){
b += in.read(filesize, b, filesize.length–b);
}
ends = 0;
for(int i=0;i<filesize.length;i++){
if(filesize[i]==‘-0‘){
ends = i;
break;
}
}
String filesizes = new String(filesize,0,ends);
System.out.println(“filesize:“+filesizes);
int ta = Integer.parseInt(filesizes);
byte[] buf = new byte[1024*10];
//InputStream ins = socket.getInputStream();
while(true){
if(ta==0){
break;
}
int len = ta;
if(len>buf.length){
len = buf.length;
}
int rlen = in.read(buf, 0, len);
//int rlen = ins.read(buf, 0, len);
ta -= rlen;
if(rlen>0){
fos.write(buf,0,rlen);
fos.flush();
}
else{
break;
}
}
out.println(“cp finish!“);
fos.close();
break;
}
else{
System.out.println(“err command!“);
out.println(“err command!“);
break;
}
}
socket.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
public
class
JCPServer
{
/**
* @param args
*/
public static void main(String[] args) throws Exception {
// TODO Auto-generated method stub
int num = args.length;
if(num<=0){
System.out.println(“please input server port!“);
System.exit(0);
}
int port = Integer.parseInt(args[0]);
System.out.println(“you input port:“+port);
//绑定接受数据端口
ServerSocket s = new ServerSocket(port);
while(true){
Socket socket = s.accept();
new CPThread(socket).start();
}
}
}
client 端
import
java.io.BufferedWriter;
import
java.io.File;
import
java.io.FileInputStream;
import
java.io.OutputStream;
import
java.io.OutputStreamWriter;
import
java.io.PrintWriter;
import
java.net.InetAddress;
import
java.net.Socket;
public
class
JCPClient
{
/**
* @param args
*/
public static void main(String[] args)throws Exception {
// TODO Auto-generated method stub
int num = args.length;
if(num<=3){
System.out.println(“please input server ip port filefrom fileto!“);
System.exit(0);
}
System.out.println(“host:“+args[0]);
System.out.println(“port:“+args[1]);
System.out.println(“filefrom:“+args[2]);
System.out.println(“fileto:“+args[3]);
InetAddress addr = InetAddress.getByName(args[0]);
Socket socket =
new Socket(addr, Integer.parseInt(args[1]));
OutputStream out = socket.getOutputStream();
byte[] cmd = new byte[128];
byte[] tcmd = “cp“.getBytes();
for(int i=0;i<tcmd.length;i++){
cmd[i] = tcmd[i];
}
cmd[tcmd.length] = ‘-0‘;
out.write(cmd,0,cmd.length);
//文件名称
byte[] file = new byte[256];
byte[] tfile = args[3].getBytes();
for(int i=0;i<tfile.length;i++){
file[i] = tfile[i];
}
file[tfile.length] = ‘-0‘;
out.write(file,0,file.length);
//大小
File filein = new File(args[2]);
byte[] size = new byte[64];
byte[] tsize = (“”+filein.length()).getBytes();
for(int i=0;i<tsize.length;i++){
size[i] = tsize[i];
}
size[tsize.length] = ‘-0‘;
out.write(size,0,size.length);
FileInputStream fis = null;
byte[] buf = new byte[1024*10];
//char[] bufC = new char[1024*10];
fis = new FileInputStream(filein);
int readsize = 0;
//OutputStream ops = socket.getOutputStream();
while((readsize = fis.read(buf, 0, buf.length))>0){
out.write(buf,0,readsize);
out.flush();
}
socket.close();
}
}
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/118337.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...