黑马程序员技术交流社区

标题: TCP传输采用PrintWriter的问题 [打印本页]

作者: 梁航斌 时间: 2013-4-9 12:51
标题: TCP传输采用PrintWriter的问题
本帖最后由梁航斌于 2013-4-10 20:02 编辑

PrintWriter用起来很方便，还能自动刷新，可是我自己写了个客户端上传图片到服务端的例子出问题了，图片大小变小了。我怀疑是pw.write(new String(buf,0,len));这里出的问题，我自己后来换了BufferedOutputStream就解决了，但是请问PrintWriter这个问题怎么解决呢，我加了flush（）比不加的时候得出的图片要大几K，不是自动刷新吗？怎么差别就那么大呢？
上代码了

import java.io.*;
import java.net.*;
//客户端
class Client
{
public static void main(String args[]) throws Exception{
if(args.length!=1){
System.out.println("一次仅能传送一张图片");
return;
}
if(!args[0].endsWith(".jpg")){
System.out.println("请注意图片格式，仅支持.jpg");
return;
}
File file = new File(args[0]);
if(file.length() > 1024*1024*5){
System.out.println("文件不能超过5M");
return;
}
System.out.println(args[0]);
//建立Socket指向发送没标和端口
Socket s = new Socket(InetAddress.getByName("192.168.1.4"),10000);
//建立读取流对象，采用BufferedInputStream读取本地图片
BufferedInputStream bis = new BufferedInputStream(new FileInputStream(file));
//获取Socket对象的写入流，封装成PrintWriter提高效率
PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
//定义字节缓冲区
byte []buf = new byte[1024];
int len = 0;
//循环读取写入到服务端
while((len = bis.read(buf))!=-1){
pw.write(new String(buf,0,len));
}
//告诉服务端这边写完了
s.shutdownOutput();
//获取Socket读取流，封装BufferedInputStream读取服务端返回的数据
BufferedInputStream rbis = new BufferedInputStream(s.getInputStream());
//因为就一句话，所以就不用循环了
byte []b = new byte[1024];
int num = rbis.read(b);
System.out.println(new String(b,0,num));
rbis.close();
pw.close();
s.close();
}
}

复制代码

import java.io.*;
import java.net.*;
class Server
{
public static void main(String []args) throws Exception{
//建立服务端对象，监听10000端口
ServerSocket ss = new ServerSocket(10000);
//循环控制客户端运行各自的线程
while(true){
//accept()是阻塞式的，因此不会陷入死循环
Socket s = ss.accept();
//开启对象各自的线程
new Thread(new UpLoad(s)).start();
}
}
}
class UpLoad implements Runnable
{
private Socket s;
UpLoad(Socket s){
this.s = s;
}
public void run(){
try{
//当客户端连接成功后服务端显示其ip
String ip = s.getLocalAddress().getHostAddress();
System.out.println(ip+"......连接成功");
//定义计数器
int count = 1;
//定义一个File,用ip为图片命名，避免同名采用循环判断
File file = new File("D:\\"+ip+".jpg");
if(file.exists()){
file = new File("D:\\"+ip+"("+(count++)+")"+".jpg");
}
//获取Socket对象的读取流，采用BufferedInputStream提高效率
BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
//写入流采用PrintWriter
PrintWriter pw = new PrintWriter(new FileOutputStream(file),true);
byte []buf = new byte[1024];
int len = 0;
while((len = bis.read(buf))!=-1){
pw.write(new String(buf,0,len));
}
//告诉客户端这边读完了
s.shutdownInput();
//获取Socket对象的写入流，然后发送“上传成功”给客户端
PrintWriter rpw = new PrintWriter(s.getOutputStream());
rpw.write("上传成功");
rpw.flush();
rpw.close();
pw.close();
s.close();
}
catch(Exception e){
}
}
}

复制代码

作者: 黑马李超 时间: 2013-4-9 13:22
在PrintWriter构造方法中，加上autoFlush标记，如果标记为true，只对println，printf，format三个方法有效，会自动刷新。write方法是不会自动刷新的。

作者: 梁航斌 时间: 2013-4-9 13:29

黑马李超发表于 2013-4-9 13:22
在PrintWriter构造方法中，加上autoFlush标记，如果标记为true，只对println，printf，format三个方法有效 ...

但是我也加了flush（）；啊，这咋回事？

作者: 贾振凯 时间: 2013-4-9 15:33
本帖最后由贾振凯于 2013-4-9 15:45 编辑

这个问题应该是跟编码有关,
API文档里有这么一句话:--------PrintWriter不包含用于写入原始字节的方法，对于这些字节，程序应该使用未编码的字节流进行写入。

而音视频和图片文件里存储的都是原始字节,你在使用new String()方法时默认是要解码的,但是你的图片压根就没编码,解码从何谈起,在这里字节码应该就已经乱了
服务端用的字节流,读到的应该就是乱码了吧!至于刷新对文件大小的影响:我随便试了一下,刷新与不刷新都比原来的小且结果一样

public class ReflectDemo {
public static void main(String[] args) throws IOException {
BufferedInputStream bis = new BufferedInputStream(new FileInputStream("E:\\Pier.jpg"));
PrintWriter pw = new PrintWriter(new FileOutputStream("E:\\Pier2.jpg"),true);
byte[] buf = new byte[1024];
int len=0;
while((len=bis.read(buf)) != -1){
pw.write(new String(buf,0,len));
pw.flush();
}
}
}

复制代码

另外关于字节流读取音视频及图片文件的字节码的实现原理在毕来师第19天13个视频(自定义具有缓冲功能的字节流)有详细讲解!

以上是我的猜测,仅供参考哈呵呵!

作者: 梁航斌 时间: 2013-4-9 15:44

贾振凯发表于 2013-4-9 15:33
这个问题应该是跟编码有关,
API文档里有这么一句话:--------PrintWriter不包含用于写入原始字节的方法，对 ...

我也怀疑是编码问题，用BufferedWriter都没事。试了一下传txt，发现可以传，没乱码。

欢迎光临黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2