DataInputStream的使用,读阻塞

最新推荐文章于 2022-05-09 16:30:28 发布

webclw

最新推荐文章于 2022-05-09 16:30:28 发布

阅读量6.2k

点赞数 1

分类专栏：历史难题+解决办法文章标签： import server null thread exception byte

版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。

本文链接：https://blog.csdn.net/webclw/article/details/1530820

版权

历史难题+解决办法专栏收录该内容

5 篇文章

订阅专栏

今天写了个程序,观看HTTP上传文件的流格式,发现:

DataInputSteam的 readFully(byte b[ ] )方法,当不能完全填充b[ ]时, 会阻塞程序的执行,直到读到足够的数据为止,

程序才继续执行下去!

代码:

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.EOFException;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

public class HttpServer extends Thread {

private int SERVER_PORT=3221;

private ServerSocket s=null;

public HttpServer() throws IOException{

s=new ServerSocket(SERVER_PORT);

}

public HttpServer(int SERVER_PORT) throws IOException{

this.SERVER_PORT=SERVER_PORT;

s=new ServerSocket(SERVER_PORT);

}

public void run(){

try {

while(true){

Socket socket=s.accept();

System.out.println("响应客户端："+System.currentTimeMillis());

new Answer2Client(socket).start();

}

} catch (IOException e) {

System.out.println("HttpServer-->run()方法中出错");

e.printStackTrace();

}

}

public static void main(String sssp[]) throws Exception{

HttpServer server=null;

if(sssp.length!=0)

server=new HttpServer(Integer.parseInt(sssp[0]));

else

server=new HttpServer();

server.start();

}

}

class Answer2Client extends Thread {

private Socket client=null;

private byte[] b=new byte[10240];

public Answer2Client(Socket ss){

this.client=ss;

}

public void run(){

try {

BufferedReader datain=new BufferedReader(new InputStreamReader(client.getInputStream()));

while(true){

// datain.readFully(b);

String line=datain.readLine();

if(line==null)break;

System.out.println(line);

}//while

System.out.println(" 结--------束");

}catch(IOException e) {

System.out.print(" 结束");

e.printStackTrace();

}

//响应

DataOutputStream dataout;

try {

dataout = new DataOutputStream(client.getOutputStream());

String time=System.currentTimeMillis()+" 时间time";

dataout.writeChars("<html>"+time+"</html>");

dataout.flush();

dataout.close();

client.shutdownOutput();

client.shutdownInput();

client.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

程序不能正长结束,不知道怎么关闭套界字,和流

博客等级

码龄18年

13
原创

1
点赞

4
收藏

4
粉丝

关注

私信

热门文章

分类专栏

展开全部收起

上一篇：: struts的formbean的存活范围对程序的影响

下一篇：: ORACLE存小文件和大文件做法

最新评论

iBATIS的Date数据类型
九条腿咸鱼: 是吗?那具体要怎么做呢?
Ibatis批处理SqlMapClient使用不关闭,资源耗尽,死锁错误!
owen163: 写得不错,支持一下!貌似有时会有这种问题!
Ajax的POST方法中文乱码问题解决
秋忆: 谢谢了
ORACLE存大文件出现错误:读取违反顺序
webclw: jdbc中如何处理Oracle BLOB字段为什么我要写这篇文章？在前段时间我所在的项目中，就碰到了这个问题，我花了2天的时间才将BLOB的问题搞定。我也尝试过网上所介绍的各种方法，那些方法所使用的原理都一致，但都写得不完整，我也按照网上介绍的方法做了，但都因为其中一些没有提到的小的细节而失败。希望看到这篇文章的人都不再走弯路。一般人会走哪些弯路？ 1.使用jdk中的方法进行传输。在ResultSet 中有getBlob()方法，在PreparedStatement中有setBlob()方法，所以大多数人都会尝试setBlob (),getBlob() 进行读写，或者两个数据库之间BLOB的传输。这种方法实际上是行不通的，据网上的一些资料介绍，说sun官方的文档有些方法都是错误的。 2.使用ResultSet.getBinaryStream 和PreparedStatement.setBinaryStream对BLOB进行读写或两个数据库间的传输。这种方法我自己尝试过，发现，如果BLOB中存储的是文本文件的话，就没问题，如果是二进制文件，传输就会有问题。根据自己的经验，以及查阅了Oracle的官方文档，都是使用如下处理方法： 1.新建记录，插入BLOB数据 1.1首先新建记录的时候，使用oracle的函数插入一个空的BLOB，假设字段A是BLOB类型的: insert xxxtable(A,B,C) values(empty_blob(),'xxx','yyyy') 1.2后面再查询刚才插入的记录，然后更新BLOB，在查询前，注意设置Connection的一个属性: conn.setAutoCommit(false);如果缺少这一步，可能导致fetch out of sequence等异常. 1.3 查询刚才插入的记录,后面要加“ for update ”,如下： select A from xxxtable where xxx=999 for update ,如果缺少for update，可能出现row containing the LOB value is not locked 的异常 1.4 从查询到的 BLOB字段中，获取blob并进行更新，代码如下： BLOB blob = (BLOB) rs.getBlob("A"); OutputStream os = blob.getBinaryOutputStream(); BufferedOutputStream output = new BufferedOutputStream(os); 后面再使用output.write方法将需要写入的内容写到output中就可以了。例如我们将一个文件写入这个字段中： BufferedInputStream input = new BufferedInputStream(new File("c://hpWave.log").toURL().openStream()); byte[] buff = new byte
Ajax-服务器回应XML文档的中文乱码问题
webclw: Ajax中文问题终极解决办法: 我们用的异步提交办法一律为POST方法!!!页面编码为GBK或GB2312 1.浏览器向服务器提交数据中有中文, 首先,向服务器发送的查询字符串必须编码 query为查询字符传参数则: query = encodeURI(query); query = encodeURI(query);//编码两次后提交 xmlhttp.send(query); 在服务器端解码方法: return query =java.net.URLDecoder.decod(query ,"UTF-8"); 2. 服务器向浏览器发送中文,接收方式为responseText 直接response.setCharacterEncoding("GB2312"); 如果为XML文档,则 response.setCharacterEncoding("UTF-8"); 中文就能正常显示了

最新文章

目录

展开全部

收起

评论

被折叠的条评论为什么被折叠?

到【灌水乐园】发言

查看更多评论

添加红包

成就一亿技术人!

hope_wisdom

发出的红包

实付元

使用余额支付

点击重新获取

扫码支付

钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。