TCP连接也会丢包吗？

黄文伯

本帖最后由 yxz 于 2013-9-21 15:10 编辑

LZ遇到一个非常棘手问题了，连调试也麻烦，所以想请大家帮我看看问题出在哪里。
这个程序可以接受一个参数（文件的路径）发送参数下的文件。如果不接受参数则会监听端口。
有时候接收的文件比原始文件小。通常是启动服务端的第一次接收。

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
public class TextShowOnTcp {
public static void main(String[] args) throws IOException {
int arglen=args.length;
if(arglen==0)
new ServerThread().start();
else
new SendThread(new File(args[0])).start();
}
}
class ServerThread extends Thread{
@Override
public void run() {
ServerSocket Server=null;
try {
Server=new ServerSocket(5555);
while(true){
Socket nowSocket=Server.accept();
BufferedReader readfilename =new BufferedReader(new InputStreamReader(nowSocket.getInputStream()));
File newfile = new File("C:\\"+readfilename.readLine());
if (!newfile.exists()){
BufferedOutputStream outputpath = new BufferedOutputStream(new FileOutputStream(newfile));
InputStream filestream=nowSocket.getInputStream();
byte[] buffer=new byte[1024*10];
int len=0;
while ((len=filestream.read(buffer))!=-1) {
outputpath.write(buffer, 0, len);
}
System.out.print("上传成功");
outputpath.close();
}
else {
nowSocket.shutdownInput();
}
}
} catch (IOException e) {
e.printStackTrace();
} finally{
try {
Server.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
class SendThread extends Thread{
File file=null;
public SendThread(File f) {
file=f;
}
@Override
public void run() {
try {
Socket Send = new Socket("192.168.1.204",5555);
BufferedOutputStream Pso =new BufferedOutputStream(Send.getOutputStream());
Pso.write((file.getName()+"\r\n").getBytes());
Pso.flush();
InputStream bin=new FileInputStream(file);
byte[] buffer = new byte[1024*10];
int len;
while ((len=bin.read(buffer))!=-1) {
Pso.write(buffer,0,len);
}
Pso.close();
bin.close();
Send.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
}
}
}

复制代码

黄文伯 · 黄文伯

亲，如问题已解决请将分类的“未解决”改为“已解决”。
以后的问题贴也要及时更改分类哦~

straw · straw

楼主能加注释尽量要加注释啊!这样别人就很容易看出的你的代码想要做什么了.
目前我发现有两处错误
1,在服务端你同时nowSocket.getInputStream()));两次获取客户端的套接字节流,可能是这造成了部分字节数据丢失.
2,你的客户端中有两次向服务器发送数据,但中间过程你只做了flush()刷新动作.等于第一次客户端的套接输入流实际上服务端并没有收到.你应该在每次写完数据后进行一次套接输入流关闭动作.而服务上你也有两次获取客户端的套接字读取流,中间过程你不仅没有关闭服务端接受客户端的写入流,造成知道服务端最后执行nowSocket.shutdownInput();的时候全部数据才涌进来.所以就会出现你上传后的文件和源文件大小不同等原因.
下面是我同样功能的代码,你看下吧:

public class TcpImage {
public static void main(String[] ages) {
// 客户端
new Thread(new Runnable() {
//创建服务端套接字
Socket sk = null;
//定义文件读取流
FileInputStream fis = null;
public void run() {
try {
sk = new Socket(InetAddress.getByName("192.168.16.41"),
2008);
OutputStream os = sk.getOutputStream();
//将服务获取的读取流转换成字符流
BufferedReader bisr = new BufferedReader(
new InputStreamReader(sk.getInputStream()));
//获取原文件的读取流
fis = new FileInputStream("E:\\Images\\1.jpg");
byte[] bt = new byte[1024];
int end;
while ((end = fis.read(bt)) != -1) {
os.write(bt, 0, end);
}
//关闭客服端的写入流这不非常重要如果没有关闭该流则数据不会发送到服务端
sk.shutdownOutput();
String line;
while ((line = bisr.readLine()) != null) {
System.out.println(line);
}
} catch (Exception e) {
throw new RuntimeException("客户端异常退出");
} finally {
if (fis != null) {
try {
fis.close();
} catch (IOException e) {
throw new RuntimeException("客户端服务关闭异常");
}
}
if (sk != null) {
try {
sk.close();
} catch (IOException e) {
throw new RuntimeException("客户端服务关闭异常");
}
}
}
}
}).start();
// 服务端
new Thread(new Runnable() {
//创建一个服务套接字
ServerSocket ssk = null;
FileOutputStream fos = null;
public void run() {
try {
ssk = new ServerSocket(2002);
fos = new FileOutputStream("F:\\1_copy.jpg");
//获取服务端接受到的客户套接字
Socket sk = ssk.accept();
//获取客户套接字的读取流对象
InputStream br = sk.getInputStream();
BufferedWriter bw = new BufferedWriter(
new OutputStreamWriter(sk.getOutputStream()));
byte[] bt = new byte[1024];
int endr;
while ((endr = br.read(bt)) != -1) {
fos.write(bt, 0, endr);
}
bw.write(sk.getInetAddress()+"成功上传");
bw.newLine();
bw.flush();
//关闭服务端接受的客户端套接字的写入流这个步骤也非常重要如果没有该步那么服务端线程将处于线程等待机制
sk.shutdownOutput();
} catch (IOException e) {
throw new RuntimeException("服务端异常退出");
} finally {
if (fos != null) {
try {
fos.close();
} catch (IOException e) {
throw new RuntimeException("服务写入流关闭异常");
}
}
if (ssk != null) {
try {
ssk.close();
} catch (IOException e) {
throw new RuntimeException("服务关闭异常");
}
}
}
}
}).start();
}
}

复制代码

yxz · yxz

straw 发表于 2013-9-21 01:12
楼主能加注释尽量要加注释啊!这样别人就很容易看出的你的代码想要做什么了.
目前我发现有两处错误
1,在服务 ...

抱歉让你读了这么难看的源码。因为想要用TCP传文件名，一直有想不到好主意，才写两次getInputStream()。这样会使数据丢失，我还是有疑惑。
第一次获取数据流时是为了获取文件名，第二次是为了获取数据，问题在第一次获取时除了文件名还获取了其他数据，使第二次获取的数据不玩整。
这样理解正确吗？

straw · straw

对是这样理解的,因为你的客户端在发送文件名给服务端的时候并没有立即关闭套接输入流,所以这些数据流服务端并没能立即接受到.再次一个服务端只能一次获取客户端的套接输入流,如果同时获取多个套接输入流可能会造成套接输入流中的数据混乱.

yxz · yxz

straw 发表于 2013-9-21 11:06
对是这样理解的,因为你的客户端在发送文件名给服务端的时候并没有立即关闭套接输入流,所以这些数据流服务端 ...

非常感谢，对我帮助很大。

潘才新 · 潘才新

straw 发表于 2013-9-21 01:12
楼主能加注释尽量要加注释啊!这样别人就很容易看出的你的代码想要做什么了.
目前我发现有两处错误
1,在服务 ...

技术很强大！

帐号		自动登录	找回密码
密码			加入黑马

TCP连接也会丢包吗？

评分

6 个回复

评分