Java 网络编程一---Socket(Tcp+Udp)

更详细网络知识请点击这里

两台计算机进行网络通信，必须满足一下三点

IP 地址：两台主机必须有唯一的标识
协议：双方必须拥有共同的语言，否则出现言语不通，无法交流。
端口号：一台主机上可以运行多个应用程序，如何辨别不同应用程序的通信，就需要端口号来区分

TCP/IP 协议

TCP/IP 协议是目前引用最为广泛的协议，是以 TCP 和 IP 为基础的不同层次上多个协议的集合，也称 TCP/IP 协议族或协议栈

TCP：Transmission Control Protocol 传输控制协议
IP： Internet Protocol 互联网协议

TCP/IP 模型

物理层——>链路层——>网络层——>传输层——>引用层

物理层是用户最直观接触到的，比如网线、双绞线、网卡等
TCP/IP 协议实际上是在第4层传输层
应用层有许多协议是大家熟知的：HTTP 超文本传输协议、FTP 文件传输协议（可进行文件上传、下载等传输）、SMTP 简单邮件传输协议、Trlnet 远程登录服务

IP 地址

为实现网络中不同计算机之间的通信，每台计算机都必须有一个唯一的标识---IP地址（类似生活中手机通信，双方就必须拥有各自的手机号才能通信）

IP 地址格式：数字型，如 192.168.0.1（类似手机号码规定了11位）

端口

一台主机可以使用多个应用程序，当某个应用与另一台计算机通信时，如何保证发送的消息被对面正确接收（比如说A计算机中QQ发送消息到B计算机QQ中，而不是B计算机的微信中），使用端口就能保证，每个应用都有各自的唯一端口号。

用于区分不同应用程序
端口号范围为0_{65535，其中0}1023为系统所保留
IP 地址和端口号组成了所谓的 Socket，Socket是网络上运行的程序之间双向通信链路的终结点，是 TCP 和 UDP 的基础
常见默认协议端口，http：20，ftp：21，telnet：23

JAVA 中的网络支持

针对网络通信的不同层次，Java 提供的网络功能有四大类

InetAddress：用于标识网络上的硬件资源，即标识 IP 地址
URL：统一资源定位符，表示Internet 上某一资源的地址，通过 URL 可以直接读取或写入网络上的数据
Socket：使用 TCP 协议实现网络通信的 Socket 相关的类
Datagram：使用 UDP 协议，将数据保存在数据报中，通过网络进行通信

InetAddress 类常用方法的使用

package com.fy.inetaddress;

import java.lang.reflect.Array;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Arrays;

public class Demo1 {

    public static void main(String[] args) {
        try {
            //获取本机的InetAddress实例
            InetAddress inetAddress = InetAddress.getLocalHost();
            System.out.println("计算机地址："+inetAddress.getHostAddress());
            System.out.println("计算机名："+inetAddress.getHostName());
            byte[] bytes = inetAddress.getAddress();//直接获取字节数组形式的IP地址
            System.out.println("字节数组形式的IP"+Arrays.toString(bytes));
            System.out.println(inetAddress);//直接输出InetAddtress实例
            
            System.out.println("---------------");
            //根据电脑名称获取InetAddress实例        
            InetAddress inetAddress2 = InetAddress.getByName("DESKTOP-FCI9M7Q");
            System.out.println("计算机地址："+inetAddress2.getHostAddress());
            System.out.println("计算机名："+inetAddress2.getHostName());
        
            System.out.println("---------------");
            //根据电脑IP地址也能获取实例
            InetAddress inetAddress3 = InetAddress.getByName("192.168.56.1");
            System.out.println("计算机地址："+inetAddress2.getHostAddress());
            System.out.println("计算机名："+inetAddress2.getHostName());
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

}

URL 类常用方法的使用

package com.fy.url;

import java.net.MalformedURLException;
import java.net.URL;

public class URLDemo {

    public static void main(String[] args) {
        try {
            //创建一个URL实例
            URL imooc = new URL("http://www.baidu.com");
            //通过一个存在的URL实例创建一个新的实例？表示后面的参数，#表示锚点
            URL url = new URL(imooc, "/index.html?username=tom#test");
            //获取协议
            System.out.println(url.getProtocol());
            System.out.println(url.getHost());
            //获取端口号，如果端口号未指定即使用的是默认端口号，此时返回-1
            System.out.println("查询端口："+url.getPort());
            System.out.println("查询文件路径："+url.getPath());
            System.out.println("查询文件名："+url.getFile());
            System.out.println("查询相对路径："+url.getRef());
            System.out.println("查询字符串："+url.getQuery());
        } catch (MalformedURLException e) {
            e.printStackTrace();
        }
        
    }

}

package com.fy.url;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.net.URL;

public class URLDemo2 {

    public static void main(String[] args) {
        try {
            URL url = new URL("http://www.baidu.com");
            //通过URL的openStream 方法获取URL对象所表示的资源的字节输入流
            InputStream is = url.openStream();
            //转化为字符输入流
            InputStreamReader isr = new InputStreamReader(is,"utf-8");
            //为字符输入流添加缓冲
            BufferedReader br = new BufferedReader(isr);
            String data = br.readLine();//读取数据
            while (data != null) {//循环读取数据
                System.out.print(data);//输出数据
                data = br.readLine();
            }
            br.close();
            isr.close();
            is.close();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

Tcp SocKet 通信

TCP 协议是面向连接、可靠、有序的，以字节流的方式发送数据基于 TCP 协议实现网络通信的类：

客户端的 Socket 类
服务器端的 ServerSocket 类

Tcp Socket 通信实现步骤

创建 ServerSocket 和 Socket
打开连接到 Socket 的输入/输出流
按照协议对 Socket 进行读/写操作
关闭输入输出流、关闭 Socket

服务器端

创建 ServerSocket 对象，绑定监听端口
通过 accept() 方法监听客户端的请求
建立连接后，通过输入流获取客户端的请求数据
通过输出流向客户端发送相应消息
关闭所有资源

package com.fy.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/*
 * 基于 TCP 协议的 Socket 通信，实现用户登录
 * 服务器端
 */
public class TcpServer {
    
    
    public static void main(String[] args) {
        try {
            // 1. 创建一个服务器端的ServerSocket,指定绑定端口并且监听
            ServerSocket serverSocket = new ServerSocket(6666);
            System.out.println("---服务器即将启动，等待客户端连接---");
            // 2. 调用 accept()方法监听客户端请求
            Socket socket = serverSocket.accept();
            // 3. 利用输入流读取客户端信息
            InputStream is = socket.getInputStream();//字节输入流
            InputStreamReader isr = new InputStreamReader(is);//将字节流转化为字符流
            BufferedReader br = new BufferedReader(isr);//为输入字符流创建缓冲
            
            String info = null;
            while((info=br.readLine())!=null){//循环读取客户端的信息
                System.out.println("我是服务器，客户端说"+info);
            }
            socket.shutdownInput();// 关闭输入流
            // 4.创建输出流，响应客户端的请求
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(os);//包装为打印流(与输出字符流类似)
            pw.write("服务器端说，欢迎你！");
            pw.flush();//调用 flush()方法刷新缓存
            
            // 5.关闭所有资源
            pw.close();
            os.close();
            br.close();
            isr.close();
            is.close();
            socket.close();
            serverSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
}

客户端

创建 Socket 对象，指明需要连接的服务器地址和端口号
连接建立后，通过输出流向服务器发出需求
通过输入流接收来自服务器的相应
关闭所有资源

package com.fy.socket;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

/*
 * 基于 TCP 协议的 Socket 通信，实现用户登录
 * 客户端
 */
public class TcpClient {
    public static void main(String[] args) {
        try {
            // 1.创建一个Socket，指定服务器地址和端口
            Socket socket = new Socket("localhost", 6666);
            // 2.创建一个输出流向服务器发送消息
            OutputStream os = socket.getOutputStream();// 创建输出字节流
            OutputStreamWriter osw = new OutputStreamWriter(os);//转化为字符流
            BufferedWriter bw = new BufferedWriter(osw);//创建缓冲流
            bw.write("用户名：admin；密码：123");
            bw.flush();
            socket.shutdownOutput();// 关闭输出流
            // 3. 创建输入流，接受服务器响应
            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String info = null;
            while ((info = br.readLine()) != null) {
                System.out.println("我是客户端："+info);
            }
            // 4.关闭所有资源
            br.close();
            isr.close();
            is.close();
            bw.close();
            os.close();
            socket.close();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

利用多线程实现多客户端的通信

服务器端穿件 ServerSocket，循环调用 accept() 方法等待客户端连接
客户端创建一个 Socket 并请求和服务器端连接
服务器端接受客户端请求后，创建 socket 与该客户建立专线连接
建立连接的两个 socket 在一个单独的线程进行通信
服务器端继续等待新的连接

线程代码

package com.fy.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

/*
 * 服务器线程处理类
 */
public class TcpServerThread extends Thread {
    // 和本线程相关的Socket
    Socket socket = null;

    // 构造方法初始化socket
    public ServerThread(Socket socket) {
        this.socket = socket;
    }

    // 线程操作执行响应客户端请求
    public void run() {
        InputStream is = null;
        InputStreamReader isr = null;
        BufferedReader br = null;
        OutputStream os = null;
        PrintWriter pw = null;
        try {
            // 创建输入流，响应客户端的请求
            is = socket.getInputStream();
            isr = new InputStreamReader(is);
            br = new BufferedReader(isr);

            String info = null;
            while ((info = br.readLine()) != null) {// 循环读取客户端的信息
                System.out.println("我是服务器，客户端说" + info);
            }
            socket.shutdownInput();// 关闭输入流
            os = socket.getOutputStream();
            pw = new PrintWriter(os);
            pw.write("服务器端说，欢迎你！");
            pw.flush();// 调用 flush()方法刷新缓存
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                // 关闭所有资源
                if (pw != null) {
                    pw.close();
                }
                if (os != null) {
                    os.close();
                }
                if (br != null) {
                    br.close();
                }
                if (isr != null) {
                    isr.close();
                }
                if (is != null) {
                    is.close();
                }
                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

同时将服务器该为如下代码

package com.fy.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
/*
 * 基于 TCP 协议的 Socket 通信，实现用户登录
 * 服务器端
 */
public class TcpServer {
    
    
    public static void main(String[] args) {
        try {
            // 创建一个服务器端的ServerSocket,指定绑定端口并且监听
            ServerSocket serverSocket = new ServerSocket(6666);
            Socket socket = null;
            int count = 0;
            System.out.println("---服务器即将启动，等待客户端连接---");
            // 利用while循环监听
            while(true){
                 // 调用 accept()方法监听,等待客户端请求
                 socket = serverSocket.accept();
                 // 创建一个新的线程
                 TcoServerThread sThread = new TcpServerThread(socket);
                 // 启动一个线程
                 sThread.start();
                 count++;// 统计客户端的数量
                 System.out.println("客户端的数量："+count);
                 //创建InetAdress对象，以获取客户端IP地址
                 InetAddress address = socket.getInetAddress();
                 System.out.println("当前客户端的Ip地址："+ address.getHostAddress());
            }
        
            
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
}

最后编辑于：2017.12.03 05:08:00

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 204,053评论 6赞 478
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,527评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,779评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,685评论 1赞 276
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,699评论 5赞 366
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,609评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,989评论 3赞 396
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,654评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,890评论 1赞 298
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,634评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,716评论 1赞 330
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,394评论 4赞 319
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,976评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,950评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,191评论 1赞 260
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 44,849评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,458评论 2赞 342