20150802-网络连接-TCP

[TOC]

TCP IP协议：必须建立连接。

一、各种网络连接结构

. BS结构：不需要客户端，例如一般的网页结构。

. CS结构:需要客户端（这里我们主要介绍CS结构）。

. P2P结构：例如有服务器的BT种子下载。

二、InetAddress 类

1.一定不能new对象，因为InetAddress 类中构造器私有化了，不对外开放，

要利用getLocalHost()方法。

2.获得主机名：getHostName()

获得主机地址：getHostAddress()

3.InetAddress 在返回主机时会有一个异常。

public class Test04 {
    public static void main(String[] args) {
        try {
            InetAddress ia = InetAddress.getLocalHost(); //有UnknownHostException异常
            System.out.println("主机名为："+ia.getHostName());
            System.out.println("主机地址："+ia.getHostAddress());
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}
/*结果：
主机名为：lingzhuo21-5
主机地址：192.168.0.74
*/

三、客户机Socket 和服务器端ServerSocket(java.net.Socket)

注意：（读：输入流；写：输出流）

1.由于正在通话就没有bw.close();socket.close();

2.必须先启动服务端，让其等待，再运行客户端。

一）简单范例：

/*服务器端：
步骤：
<1>建立套接字ServerSocket 
<2>利用accept(）方法监听
<3>读流：通过BufferedReader读取客户端传过来的字。
（利用套接字中的getInputStream()方法来获得输入流）
*/
public static void main(String[] args) {
        try {
            System.out.println("服务端启动，在监听！");
            ServerSocket server = new ServerSocket(8080);//8080端口监听，且有IOException异常
            Socket socket = server.accept(); //监听当连接成功则返回一个套接字
            //读传过来的值
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String s = br.readLine();
            System.out.println("有连接进入："+s);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}

//客户端：
/*
注：由于服务器端用readline方法是读一行，所以客户端在传入字符时后面要加\n，让它知道
这一行结束。
步骤：
<1>创建Socket 套接字（套接字中传入服务器ip地址和端口）
<2>写入字符（利用套接字中的getOutputStream()方法获得输出流）
<3>注意flush（）;
*/
public class MyClient {
    public static void main(String[] args) {
    System.out.println("客户端启动");
    try {
        Socket socket = new Socket("192.168.0.74",8080);//异常IOException
    //写入:socket.getOutputStream()获得输出流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        bw.write("nihao!\n");
        bw.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

二）范例二：聊天

要求：

1.客户端与服务器端通信

2.客户端一句服务器端一句（必须的格式）

/*
服务器端：
步骤：
<1>套接字ServerSocket 
<2>accept阻塞，等待客户机连接
<3>输入输出缓冲对象，获取控制台输入对象
<4>循环：
    1*等待读客户机数据,并输出（读流，readLine方法）-----注意：写入的数据就得多加\n
    2*然后从控制台输入返给客户端的数据
    3*将数据写到流中，并flush（）；
*/
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;
public class MyService {

    public static void main(String[] args) {
        try {
            ServerSocket server = new ServerSocket(8080);//8080端口监听，且有IOException异常
            System.out.println("服务端启动，在监听！");
            Socket socket = server.accept(); //监听当连接成功则返回一个套接字
            //读传过来的值
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

            Scanner scanner = new Scanner(System.in);
            while(true){
                String s = br.readLine(); //2.先阻塞，等待客户机数据
                System.out.println("客户机返回:"+s);//3.收到客户机数据显示
                String back = scanner.next();   //4.返回给客户机数据（控制台写入）
                bw.write(back+"\n");
                bw.flush();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}

/*
客户机端：
步骤：
<1>套接字，建立连接
<2>输入输出流对象，控制台获取对象
<3>循环：
   1*客户端先从控制台写入（sanner.next()并
   2*write到流中，并flush；
   3*等待获取服务器端的返回数据
   4*显示获取到的返回数据。
*/
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;

public class MyClient {
    public static void main(String[] args) {
        System.out.println("客户端启动");
        try {
            Socket socket = new Socket("192.168.0.74",8080);//异常IOException
            //写入:socket.getOutputStream()获得输出流
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            Scanner sanner = new Scanner(System.in);
            while(true){
                String s = sanner.next();  //1.客户端先写入
                bw.write(s+"\n");
                bw.flush();         //注：不要忘了flush
                String back = br.readLine();
                System.out.println("服务端的返回："+back);
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}

解析：系统阻塞的地方：

1.server.accept();服务器等待客户机连接

2.br.readLine()；等待数据