网络编程之TCP

TCP通信

TCP通信是严格区分客户端与服务器端的，在通信时，必须先由客户端去连接服务器端才能实现通信，服务器端不可以主动连接客户端，并且服务器端程序需要事先启动，等待客户端的连接。

在JDK中提供了两个类用于实现TCP程序，一个是ServerSocket类，用于表示服务器端，一个是Socket类，用于表示客户端。

通信时，首先创建代表服务器端的ServerSocket对象，该对象相当于开启一个服务，并等待客户端的连接，然后创建代表客户端的Socket对象向服务器端发出连接请求，服务器端响应请求，两者建立连接开始通信。

 ServerSocket类：该类的实例对象可以实现一个服务器段的程序。

　　ServerSocket对象负责监听某台计算机的某个端口号，在创建ServerSocket对象后，需要继续调用该对象的accept()方法，接收来自客户端的请求。当执行了accept()方法之后，服务器端程序会发生阻塞，直到客户端发出连接请求，accept()方法才会返回一个Scoket对象用于和客户端实现通信，程序才能继续向下执行。

　　

 Socket 类：　　实现TCP客户端程序。

在Socket类的常用方法中，getInputStream()和getOutStream()方法分别用于获取输入流和输出流。当客户端和服务端建立连接后，数据是以IO流的形式进行交互的，从而实现通信。

要实现TCP通信需要创建一个服务器端程序和一个客户端程序，为了保证数据传输的安全性，首先需要实现服务器端程序。

package udpdemo;

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


public class TCPClient {
    private static int port=9999;
    private static String ip="127.0.0.1";
    
    
    public static void main(String[] args) throws IOException, IOException {
         byte[] bytes = new byte[1024];
         int len=0;
         int l=0;
         byte[] b= new byte[1024];
        //创建客户端Socket,指定要连接的端口和ip;
        Socket socket = new Socket(ip,port);
    
        /**
         * 读取本地文件("E：\1\tx.jpg")
         * 向服务器上传文件
         */
        FileInputStream fis = new FileInputStream("E:\1\tx.jpg");
        OutputStream out = socket.getOutputStream();
        
        while((l=fis.read(b))!=-1) {
            out.write(b,0,l);
        }
        
        System.out.println("文件发送成功....");
        socket.shutdownOutput();//不加这句，上传的文件无法使用，还在被服务器占用，
                                    //shutdownOutput()发送消息告诉服务器，传送完毕，可以释放资源了
        
        
        /**
         * 读取服务器的反馈信息
         */
        //创建一个保存信息的字节数组
        //获取输入流
        InputStream in = socket.getInputStream();
        while((len=in.read(bytes))!=-1) {
            System.out.println(new String(bytes,0,len));
        }
        fis.close();
        in.close();
        socket.close();
    }
}
/**************************************输出结果***************************************/
文件发送成功....
恭喜，连接服务器成功...

package udpdemo;

import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * TCP通信     服务器端
 * ServerSocket
 * 
 *
 */
public class TCPServer {
    public static void main(String[] args) throws IOException {
        //创建服务器对象，指定服务器端口号（9999）
        ServerSocket server=new ServerSocket(9999);
        //accept()开启服务器，等待客户端连接，连接后返回一个客户端Socket对象
        Socket socket = server.accept();
        //获取客户端连接对象
        InetAddress  ipObject=socket.getInetAddress();
//        显示哪个ip连接了服务器
        System.out.println("客户端："+ipObject.getHostAddress()+"连接上了服务器");
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("F:\a\a.jpg"));
        /**
         * 通过客户端socket对象获得输入流，从而可以实现读取数据,通过accept()方法获取正在连接服务器的客户端的对象，
         * 调用客户端对象的输入流去读取客户端输出的数据，
         * 
         */
        InputStream in = socket.getInputStream();
        //输入流循序读取客户端传来的数据,并通过输出流写入文件，实现上传功能
        byte[] bytes = new byte[1024];
        int len =0;
        while((len=in.read(bytes))!=-1) {
            bos.write(bytes,0,len);
        }
        System.out.println("文件上传成功...");
        /*
         *     服务器的反馈信息
         */
        //通过Socket对象，拿到getOutputStream(),获取输出流，回复客户端"连接服务器成功"
            OutputStream out=socket.getOutputStream();
            out.write("恭喜，连接服务器成功...".getBytes());
        //关闭流资源
            bos.close();
            out.close();
            socket.close();
    }
}
/****************************************输出结果***************************************/
客户端：127.0.0.1连接上了服务器
文件上传成功...