流读取的有关问题
日期：2014-05-20 浏览次数：20750 次
流读取的问题。
第一个例子（这个例子，说明我的这个读取方法没错）
server端可以输出字符串welcome
然后就是在此基础上，实现客户端和服务端的双向通讯。问题就来了
第一个例子（这个例子，说明我的这个读取方法没错）
package com.shengsiyuan.network.e3;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 监听端
*/
public class ServerTest1
{
private static ServerSocket serverSocket;
public static void main(String[] args) throws Exception
{
serverSocket = new ServerSocket(5000);
Socket socket = serverSocket.accept();
InputStream is = socket.getInputStream();
byte[] buffer = new byte[200];
int length = 0;
String string = null;
while (-1 != (length = is.read(buffer, 0, buffer.length)))
{
string = new String(buffer, 0, length);
}
is.close();
socket.close();
serverSocket.close();
System.out.println(string);
}
}
package com.shengsiyuan.network.e3;
import java.io.OutputStream;
import java.net.Socket;
/**
* 发送字符串welcome
*/
public class ClientTest1
{
public static void main(String[] args) throws Exception
{
Socket socket = new Socket("localhost", 5000);
OutputStream os=socket.getOutputStream();
os.write("welcome".getBytes());
os.close();
socket.close();
}
}
server端可以输出字符串welcome
然后就是在此基础上，实现客户端和服务端的双向通讯。问题就来了
package com.shengsiyuan.network.e2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class MainServer
{
private static ServerSocket serverSocket;
public static void main(String[] args) throws Exception
{
serverSocket = new ServerSocket(4000);
while (true)
{
Socket socket = serverSocket.accept();
// 启动读写线程
new ServerInputThread(socket).start();
new ServerOutputThread(socket).start();
}
}
}
class ServerInputThread extends Thread
{
private Socket socket;
免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
