简单的tcp应用

tcp的定义

TCP/IP协议族按照层次由上到下，层层包装。

应用层

这里面有http，ftp,等等我们熟悉的协议。

传输层

著名的TCP和UDP协议就在这个层次

网络层

IP协议,它负责对数据加上IP地址和其他的数据（后面会讲到）以确定传输的目标。

数据链路层

这个层次为待传送的数据加入一个以太网协议头，并进行CRC编码，为最后的数据传输做准备。
发送协议的主机从上自下将数据按照协议封装，而接收数据的主机则按照协议从得到的数据包解开，最后拿到需要的数据。这种结构非常有栈的味道，所以某些文章也把tcp/ip协议族称为tcp/ip协议栈。
而我现在要学习的就是tcp的简单实用

在tcp的编程有两个关键字Socket和serverSocket,实现了基本的双向传输，下面是简单的例子让我们来简单的理解tcp的通信

首先创建tcp套接字,并制定服务器和端口号
获取套接字的输入输出流
发送字符串并回馈给服务器，从服务器接受回馈信息，
打印回馈的字符串
关闭套接字
服务器：
创建服务器套接字
永久迭代，迭代处理心连接请求
报告已连接的客户端
获取输入输出流
接收数据并复制数据，直到客户端关闭
如何让两个不同的终端通信，最简单的就是协议，按照什么规则去连接传输解码，这样才能够利于维护和扩展
java客户端

package tcpclient;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketException;

public class TCPEchoClient {
	/**
	 *
	 * @author lxh
	 * @param args
	 * @throws IOException
	 * @version 1.0
	 * @throws
	 */
public static void main(String[] args)throws  IOException {
	//判断输入的参数
	if((args.length<2)||(args.length>3))
		throw new IllegalArgumentException("Parameter(s):<Server><word>[<Port>]");
	//转换为数组，
	String server=args[0];
	byte[] data=args[1].getBytes();
	int servPort=(args.length==3)?Integer.parseInt(args[2]):7;
	Socket socket=new Socket(server,servPort);
	System.out.println("Connected to server...sending echo string");
	//获取套接字的输入输出流
	InputStream in=socket.getInputStream();
	OutputStream out=socket.getOutputStream();
	out.write(data);//读写数据
	int totalBytesRcvd=0;
	int bytesRcvd;
	//接受服务器返回的数据
	while(totalBytesRcvd<data.length){
		if((bytesRcvd=in.read(data, totalBytesRcvd, data.length-totalBytesRcvd))==-1)
			throw new SocketException("Connection closed permaturely");
		totalBytesRcvd+=bytesRcvd;
	}
	System.out.println("Received:"+new String(data));
	socket.close();
}


}

java的服务器端

package tcpclient;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;


public class TCPEchoServer {

	private static final int BUFSIZE = 32;

	public static void main(String[] args)throws IOException {
		if(args.length!=1)
			throw new IllegalArgumentException("Parameter(s):<Port>");
		int servPort=Integer.parseInt(args[0]);
		ServerSocket servsock=new ServerSocket(servPort);
		int recvMsgSize;
		byte[] receiveBuf=new byte[BUFSIZE];
		while(true){
			Socket clntSock=servsock.accept();
			SocketAddress clientAddress=clntSock.getRemoteSocketAddress();
			System.out.println("Handing clinet at"+clientAddress);

		InputStream in=clntSock.getInputStream();
		OutputStream out=clntSock.getOutputStream();
		while((recvMsgSize=in.read(receiveBuf))!=-1){
			out.write(receiveBuf,0,recvMsgSize);
		}
		clntSock.close();
}
	}
}