Java入门系列-24-实现网络通讯

时间 2019-12-10

标签 java 入门系列实现网络通讯栏目 Java 繁體版

原文原文链接

互联网上那么多设备，java 是如何与其余设备通讯的呢？此次的内容是网络通讯的基础，有了它我们才能上网页、玩游戏、视频聊天。java

Socket 客户端套接字

Socket 客户端套接字，用于链接互联网提供服务的设备。服务器

Socket 构造方法网络

构造方法	说明
Socket()	经过系统默认类型的 SocketImpl 建立未链接套接字
Socket(String host, int port)	建立一个流套接字并将其链接到指定主机上的指定端口号

经常使用方法多线程

方法名称	说明
getOutputStream()	返回此套接字的输出流
getInputStream()	返回此套接字的输入流

下面示例模拟了一个 HTTP 请求app

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class TestSocket {

    public static void main(String[] args) {
        
        //建立套接字
        try(Socket s=new Socket("www.baidu.com", 80);){
            //建立向服务器发送数据的输出流
            OutputStream os=s.getOutputStream();
            StringBuffer sb=new StringBuffer();
            //HTTP协议 请求报文
            sb.append("GET / HTTP/1.1\r\n");
            sb.append("Host: www.baidu.com:80\r\n");
            sb.append("Connection: Keep-Alive\r\n");
            //这里必定要一个回车换行，表示消息头完，否则服务器会等待
            sb.append("\r\n");
            //发送
            os.write(sb.toString().getBytes());
            //获取服务器相应内容 
            InputStream is=s.getInputStream();
            //经过输入流建立扫描器，并指定编码为utf-8防止中文乱码
            Scanner scanner=new Scanner(is,"utf-8");
            
            while(scanner.hasNextLine()) {
                String line=scanner.nextLine();
                System.out.println(line);
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
            System.out.println("未知主机");
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("IO异常");
        }
    }
}

ServerSocket

ServerSocket：实现服务器套接字，服务器套接字等待请求经过网络传入。它基于该请求执行某些操做，而后可能向请求者返回结果。socket

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class TestServerSocket {

    public static void main(String[] args) {
        //建立 ServerSocket 监听1666端口
        try(ServerSocket server=new ServerSocket(1666)){
            //阻塞方法，当有客户端连入，获取客户端Socket
            try(Socket client=server.accept()){
                //获取客户端发送的数据
                InputStream is=client.getInputStream();
                //获取向客户端发送数据的流
                OutputStream os=client.getOutputStream();
                //经过输入流建立扫描器
                try(Scanner scanner=new Scanner(is)){
                    
                    PrintWriter pw=new PrintWriter(os,true/*自动刷新*/);
                    //向客户端发送消息
                    pw.println("Hello,enter bye to exit.");
                    boolean done=false;
                    //客户端有输入数据而且没有发送 bye 
                    while(!done&&scanner.hasNextLine()) {
                        //接收客户端发送的数据
                        String line=scanner.nextLine();
                        //将客户端发送的数据发回客户端
                        pw.println("Echo:"+line);
                        //若是客户端输入bye 结束通讯
                        if(line.trim().equalsIgnoreCase("bye")) {done=true;}
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

测试方式：
在DOS 中输入命令：telnet 127.0.0.1 1666ide

telnet 不是内部或外部命令的读者，须要在 Windows 功能中启用 Telnet 客户端。测试

上面的代码若是有多个客户端连入就不行了，若是但愿服务能被多个客户端链接，可使用线程。this

多线程服务器编码

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class TestMultiServerSocket {

    public static void main(String[] args) {
        //建立 ServerSocket 监听 1666端口
        try(ServerSocket server=new ServerSocket(1666)){
            while(true) {
                //accept() 是一个阻塞方法
                Socket client=server.accept();
                InputStream is=client.getInputStream();
                OutputStream os=client.getOutputStream();
                //开启新的线程处理，传入当前客户端
                Thread t=new Thread(new ThreadEchoHandler(client));
                t.start();              
            }
            
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
class ThreadEchoHandler implements Runnable{
    private Socket socket=null;

    public ThreadEchoHandler(Socket socket) {
        this.socket=socket;
    }
    @Override
    public void run() {
        try {
            InputStream is=socket.getInputStream();
            OutputStream os=socket.getOutputStream();
            try(Scanner scanner=new Scanner(is)){
                PrintWriter pw=new PrintWriter(os,true);
                pw.println("Hello,enter bye to exit.");
                boolean done=false;
                while(!done&&scanner.hasNextLine()) {
                    String line=scanner.nextLine();
                    pw.println("Echo:"+line);
                    if(line.trim().equalsIgnoreCase("bye")) {done=true;}
                }
            }
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}

URLConnection

抽象类 URLConnection 是全部类的超类，它表明应用程序和 URL 之间的通讯连接。此类的实例可用于读取和写入此 URL 引用的资源。

Socket 能够默认任意类型的网络通讯，URLConnection 更适合 HTTP 请求，使用 URLConnection 进行HTTP操做更方便，模拟请求报文，获取响应报文和内容。

URLConnection 经常使用方法

方法	说明
connect()	打开到此 URL 引用的资源的通讯连接（若是还没有创建这样的链接）
getContentEncoding()	返回 content-encoding 头字段的值
getContentType()	返回 content-type 头字段的值
getHeaderFields()	返回头字段的不可修改的 Map
getInputStream()	返回今后打开的链接读取的输入流
setRequestProperty(String key, String value)	设置通常请求属性

获取 URLConnection 须要先建立 URL 对象：
URL url=new URL(host);

使用 URLConnection 获取网页的内容

import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Scanner;

public class TestURLConnection {
    public static void main(String[] args) {
        
        try {
            //建立URL对象
            URL url=new URL("http://www.baidu.com");
            //建立 URLConnection对象
            URLConnection connection=url.openConnection();
            //设置请求属性
            //connection.setRequestProperty("", "");
            //链接
            connection.connect();
            //获取输入流
            InputStream is=connection.getInputStream();
            //经过输入流构建一个扫描器
            Scanner scanner=new Scanner(is,"utf-8");
            while(scanner.hasNextLine()) {
                String line=scanner.nextLine();
                System.out.println(line);
            }
            System.out.println("===响应头===");
            Map<String,List<String>> headers=connection.getHeaderFields();
            for (Entry<String, List<String>> entry: headers.entrySet()) {
                String key=entry.getKey();
                System.out.print(key+":");
                for (String string : entry.getValue()) {
                    System.out.print(string);
                }
                System.out.println();
            }
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}