我有这个用于聊天客户端的Java代码其中 DataInputStream 是这样定义的:
private static DataInputStream is=null;
而且我在这一部分不断收到错误:
public void run() {
/*
* Keep on reading from the socket of the server
*/
String responseLine; //used to implement reading from the socket
try{
while((responseLine=is.readLine())!=null){ //when we recieve messages we print out here
System.out.println(responseLine); // "is" is the object of data input stream
}
closed=true;
}catch(IOException e){
System.out.println("IOException: "+e);
}
}
每次我尝试使用 javadoc 上的信息修复它时:
Deprecated. This method does not properly convert bytes to characters. As of JDK 1.1, the preferred way to read lines of text is via the BufferedReader.readLine() method. Programs that use the DataInputStream class to read lines can be converted to use the BufferedReader class by replacing code of the form:
DataInputStream d = new DataInputStream(in);
跟:
BufferedReader d = new BufferedReader(new InputStreamReader(in));
我在这一行的代码中得到另一个错误:
is=new DataInputStream(clientSocket.getInputStream());
我该如何解决这个问题?我将不胜感激,我可以在这件事上得到任何帮助
类客户端代码:
public class Clientt 实现 Runnable {//first we 实现聊天客户端
//the client socket //sience we have multiple clients we are implementing threading in our application
private static Socket clientSocket=null;
//the output stream
private static PrintStream os=null; //initializing the input & output streams
//the input stream
private static DataInputStream is=null;
private static BufferedReader inputLine=null;
private static boolean closed=false;
public static void main(String[]args)
{
//the default port
int portNumber=5000;
//the default host
String host="localhost";
if(args.length<2)
{
System.out.println("Usage:Java Client <host> <portNumber>n"
+"now using host="+host+",portNumber="+portNumber);
}
else
{
host=args[0];
portNumber=Integer.valueOf(args[1]).intValue();
}
/*
* Open a socket on a given host and port.
* Open input and Output streams
*/
try{
clientSocket=new Socket(host,portNumber); //initializing clientsocket with mentioned host and port num
inputLine=new BufferedReader(new InputStreamReader(System.in));//read input from the user using inputLine
os=new PrintStream(clientSocket.getOutputStream());//outputstream is used to write to socket
is=new DataInputStream(clientSocket.getInputStream());// inputstream is uset to read from socket
}catch(UnknownHostException e){
System.err.println("Don't know about host"+host);
}catch(IOException e) {
System.err.println("Couldn't get I/O for connection to the host"+host);
}
/*
* If everything has been initialized then we want to write some date
* to the socket we have opened a connection to on the port portNumber
*/
if(clientSocket!=null && os!=null && is!=null)
{
try{
//Creat a thread to read from the server
new Thread(new Clientt()).start(); //here we implement threading
while(!closed)
{
os.println(inputLine.readLine());//loop continues infinetely untill we terminate application and writes to socket using output stream object
}
/*
* Close the output stream,close the input stream,close the socket
*/
os.close();
is.close();
clientSocket.close();
}catch(IOException e)
{
System.out.println("IOException: "+e);
}
}
}
/*
* Creat thread to read from the server
*
*/
//@Override
public void run() {
/*
* Keep on reading from the socket of the server
*/
String responseLine; //used to implement reading from the socket
try{
while((responseLine=is.readLine())!=null){ //when we recieve messages we print out here
System.out.println(responseLine); // "is" is the object of data input stream
}
closed=true;
}catch(IOException e){
System.out.println("IOException: "+e);
}
}
}
您似乎很难正确应用BufferedReader
而不是DataInputStream
。您需要使用 InputStreamReader
将BufferedReader
和原始输入流粘合在一起。
请尝试以下更改:
首先是变量定义:
//private static DataInputStream is=null;
private static BufferedReader br=null;
然后实例化:
//is=new DataInputStream(clientSocket.getInputStream());//...
br=new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
最后,无论你在哪里is
你基本上都改用br
(因为其他使用的方法如close()
和readLine()
都存在于DataInputStream
和BufferedReader
中)。