心得13--网络编程4-TCP协议案例分析
一：简单案例：
1. 客户端
packagecom.Tcp;
importjava.io.IOException;
importjava.io.InputStream;
importjava.io.OutputStream;
importjava.net.Socket;
importjava.net.UnknownHostException;
public classClient {
/**
*@param args
*@throws IOException
* @throwsUnknownHostException
*/
public static void main(String[] args) throwsException {
// 建立客户端服务器
Socket s = newSocket("192.168.49.200",9008);
// 获取输出流对象
OutputStream out = s.getOutputStream();
out.write("我来了！！".getBytes());
//读取服务器发过来的信息
InputStream is = s.getInputStream();
byte[] buf = new byte[1024];
System.out.println(newString(buf,0,is.read(buf)));
s.close();
}
}
2.发送端
packagecom.Tcp;
importjava.io.InputStream;
importjava.io.OutputStream;
importjava.net.ServerSocket;
importjava.net.Socket;
public classServer {
/**
*@param args
*@throws Exception
*/
public static void main(String[] args) throwsException {
// 建立客户端服务器
ServerSocket ss = new ServerSocket(9008);
//调用accept()方法接收客户端发过来的文件
Socket s = ss.accept();
//获取输出流对象
InputStream is = s.getInputStream();
byte[] buf = new byte[1024];
String ip =s.getInetAddress().getHostAddress();
System.out.println(ip+":"+newString(buf,0,is.read(buf)));
//服务器端向客户返回信息
OutputStream out = s.getOutputStream();
out.write("我收到了！！".getBytes());
s.close();
ss.close(); //关了s与ss也就关了out、in，因为out、in是从s、ss中获取的
}
}
二：键盘输入案例：
1.客户端
package com.Tcp;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class Client1 {
/**
* @param 客户端通过键盘录入信息，发送到服务器端;服务器端收到信息后，将信息转为大写返回给客户端。
* @throws IOException
* @throws UnknownHostException
*/
publicstatic void main(String[] args) throws Exception {
// 建立客户端服务器
Sockets = new Socket("192.168.49.200",9008);
//获取输出流对象
OutputStreamout = s.getOutputStream();
//封装获取的输入流和输出流
System.out.println("请您输入：");
BufferedReaderbr = new BufferedReader(new InputStreamReader(System.in));
BufferedWriterbwOut = new BufferedWriter(new OutputStreamWriter(out));
BufferedReaderbrIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
Stringline = null;
while((line=br.readLine())!=null){
if(line.equals("over")){
break;
} //设置循环结束条件，也是退出命令的条件
bwOut.write(line);
bwOut.newLine(); // 换新行，字符缓冲流内部不知道换行
bwOut.flush(); //必须刷新，否则用的缓冲流输入输出会不显示
System.out.println("Server:"+brIn.readLine());
}
br.close();
s.close(); //这里的bwOut、bwInt是从out、in中获取，而out、in又是从s中获取，所以此处也不用关这两个流
}
}
2. 发送端
package com.Tcp;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
public class Server1 {
/**
* @param args
* @throws IOException
* @throws UnknownHostException
*/
publicstatic void main(String[] args) throws Exception {
// 建立客户端服务器
ServerSocketss = new ServerSocket(9008);
Sockets = ss.accept();
System.out.println(s.getInetAddress().getHostAddress()+"ServerSocket已连接！");
//获取输出流对象
InputStreamis = s.getInputStream();
//封装获取的输入流和输出流
BufferedReaderbrIn = new BufferedReader(new InputStreamReader(is));
BufferedWriterbwOut = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
Stringline = null;
while((line=brIn.readLine())!=null){
if(line.equals("over")){
break;
} // 这个if（）语句虽然与前面例子不同放到了while循环的最前面，但是跟放到最后的效果一样，不影响程序的正确性
bwOut.write("你好Client，您的消息已收到！");
bwOut.newLine();
bwOut.flush();
System.out.println("Client:"+line);
}
s.close();
ss.close(); //这里的bwOut、bwInt是从out、in中获取，而out、in又是从s中获取，所以此处也不用关这两个流
}
}
三、改造版案例（运用PrintWriter类来调用它的println（）方法，简化代码，去除刷新和换行操作）
1.Client客户端
packagecom.Tcp;
importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.io.OutputStream;
importjava.io.PrintWriter;
importjava.net.Socket;
importjava.net.UnknownHostException;
publicclassClient2 {
/**
* @param 客户端通过键盘录入信息，发送到服务器端;服务器端收到信息后，将信息转为大写返回给客户端。
* @throws IOException
* @throws UnknownHostException
*/
public staticvoid main(String[] args)throws Exception {
// 建立客户端服务器
Socket s = newSocket("192.168.49.200",9008);
// 获取输出流对象
OutputStreamout = s.getOutputStream();
//封装获取的输入流和输出流
System.out.println("请您输入：");
BufferedReaderbr = new BufferedReader(new InputStreamReader(System.in));
PrintWriter pw= new PrintWriter(out,true); //这里用PrintWriter类代替Buffered可以不用缓冲与换行的操作
BufferedReaderbrIn = new BufferedReader(newInputStreamReader(s.getInputStream()));
String line = null;
while((line=br.readLine())!=null){
if(line.equals("over")){
break;
} //设置循环结束条件，也是退出命令的条件
pw.println(line); //但是这里不能调用writer()方法，必须调用PrintWriter类的println()方法
System.out.println("Server:"+brIn.readLine());
}
br.close();
s.close(); //这里的bwOut、bwInt是从out、in中获取，而out、in又是从s中获取，所以此处也不用关这两个流
}
}
Server服务器端：
package com.Tcp;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
public class Server2 {
/**
* @param args
* @throws IOException
* @throws UnknownHostException
*/
public static void main(String[]args) throws Exception {
// 建立客户端服务器
ServerSocket ss = newServerSocket(9008);
Socket s = ss.accept();
System.out.println(s.getInetAddress().getHostAddress()+"ServerSocket已连接！");
// 获取输出流对象
InputStream is =s.getInputStream();
//封装获取的输入流和输出流
BufferedReader brIn = newBufferedReader(new InputStreamReader(is));
PrintWriter pw = newPrintWriter(s.getOutputStream(),true);
String line = null;
while((line=brIn.readLine())!=null){
if(line.equals("over")){
break;
} // 这个if（）语句虽然与前面例子不同放到了while循环的最前面，但是跟放到最后的效果一样，不影响程序的正确性
pw.println("你好Client，您的消息已收到！");
System.out.println("Client:"+line);
}
s.close();
ss.close(); //这里的bwOut、bwInt是从out、in中获取，而out、in又是从s中获取，所以此处也不用关这两个流
}
}