黑马程序员技术交流社区

标题: 网络编程TCP协议 [打印本页]

作者: 张敬培 时间: 2013-1-23 01:35
标题: 网络编程TCP协议
为什么在客户端读取服务器端返回的数据时，要将代码放到while循环中

客户端

/*
* 客户端往服务器发送数据，数据来源于键盘录入
* 服务器给客户端一个反馈，返回该数据的大写表示。
*
*/
public class ClientDemo3 {
public static void main(String[] args) throws IOException {
// 创建客户端对象
Socket s = new Socket(InetAddress.getLocalHost(), 12306);
// 包装键盘录入
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
// 把客户端直接获取到的输出流对象用BufferedWriter包装
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
s.getOutputStream()));
// 包装一个读取数据的流对象
BufferedReader brServer = new BufferedReader(new InputStreamReader(
s.getInputStream()));
// 基本读写
String line = null;
while ((line = br.readLine()) != null) {
// 判断是否over
if ("over".equals(line)) {
break;
}
// 发给服务器
bw.write(line); //haha
bw.newLine();//加上\r\n
bw.flush();//刷新
// 获取服务器数据
String server = brServer.readLine(); <font color="#ff0000">//为什么这段代码要放到while循环里面</font>
System.out.println("server:"+server);
}
// 释放资源
br.close();
s.close();
}
}

复制代码

服务器

/*
* 服务器接收客户端的数据，转成大写，返给客户端
*/
public class ServerDemo3 {
public static void main(String[] args) throws IOException {
// 创建服务器的Socket服务对象
ServerSocket ss = new ServerSocket(12306);
// 获取当前的连接的客户端
Socket s = ss.accept();
// 包装读取数据
BufferedReader br = new BufferedReader(new InputStreamReader(
s.getInputStream()));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
s.getOutputStream()));
// 获取客户端数据，转成大写，返回
String line = null;
while ((line = br.readLine()) != null) {
// 用于检测服务器是否接受到数据了
System.out.println("数据:" + line);
bw.write(line.toUpperCase());
bw.newLine();
bw.flush();
}
// 释放资源
s.close();
ss.close();
}
}

复制代码

作者: 黄锦成 时间: 2013-1-23 10:21
这个是为了当服务器有数据发到客户端时，客户端能及时收到

作者: ︶ㄣ布丁 时间: 2013-1-25 14:26
一、TCP的基本概念 TCP是专门设计用于在不可靠的英特网上提供可靠的、端到端的字节流通信的协议，是一个面向连接的协议，TCP连接是字节流而非报文流。UDP和TCP各有65536个端口号互不影响。二、单线程服务端以下代码只能实现服务端和客户端的同步对话。服务

一、TCP的基本概念　　TCP是专门设计用于在不可靠的英特网上提供可靠的、端到端的字节流通信的协议，是一个面向连接的协议，TCP连接是字节流而非报文流。UDP和TCP各有65536个端口号互不影响。
　　二、单线程服务端
　　以下代码只能实现服务端和客户端的同步对话。服务端处理完一个客户端请求，才会处理另一个客户端请求。服务器端的输出效果是Client1阻塞20秒，Client2不会执行。必须等Client1阻塞结束之后，Client2才会执行。该例子可用来学习TCP的基本语法。
　　/**
　　* TCP客户端1
　　*
　　*
　　*/
　　public class Client1
　　{
　　public static void main（String[] args） throws Exception
　　{
　　Socket socket = new Socket（"127.0.0.1", 8821）；
　　OutputStream os = socket.getOutputStream（）；
　　String msg = "黑马1";
　　Thread.sleep（20000）；
　　os.write（msg.getBytes（））；
　　os.flush（）；
　　os.close（）；socket.close（）；
　　}
　　}
　　/**
　　* TCP客户端2
　　*
　　*/
　　public class Client2
　　{
　　public static void main（String[] args） throws Exception
　　{
　　Socket socket = new Socket（"127.0.0.1", 8821）；
　　OutputStream os = socket.getOutputStream（）；
　　String msg = "黑马2";
　　os.write（msg.getBytes（））；
　　os.flush（）；
　　os.close（）；socket.close（）；
　　}
　　}
　　/**
　　* 单线程TCP服务端
　　*
　　*
　　*/
　　public class Server
　　{
　　public static void main（String[] args） throws Exception
　　{
　　// 创建端口为8821的TCP服务器端对象
　　// 8821是服务器端的端口号而客户端从某端口A连到8821,端口A是随机的
　　ServerSocket serverSocket = new ServerSocket（8821）；
　　while （true）
　　{
　　// 若无客户端发送请求则线程在此阻塞，方法不继续执行
　　Socket socket = serverSocket.accept（）；
　　System.out.println（"connected"）；
　　InputStream instream = socket.getInputStream（）；
　　ByteArrayOutputStream bos = new ByteArrayOutputStream（）；
　　int len = 0;
　　byte[] buffer = new byte[1024];
　　while （（len = instream.read（buffer）） != -1）
　　{
　　bos.write（buffer, 0, len）；
　　}
　　instream.close（）；
　　bos.flush（）；
　　bos.close（）；
　　String msg = bos.toString（）；
　　System.out.println（"客户端的IP:" + socket.getInetAddress（）。getHostAddress（））；
　　System.out.println（"客户端的端口：" + socket.getPort（））；
　　System.out.println（"客户端的信息：" + msg）；
　　}
　　}
　　}

作者: 廖成 时间: 2013-1-25 14:52
因为服务器端可能发送很多行消息，但是用了readline()方法一次只能读取一行所以要用while()循环。

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

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