网络编程（学习整理）---2--（Udp）实现简单的控制台聊天室

1、UDP协议：

　　　　　　总结一下，今天学习的一点知识点！

　　　　　　UDP也是一种通信协议，常被用来与TCP协议作比较！我们知道，在发送数据包的时候使用TCP协议比UDP协议安全，那么到底安全在哪里呢？怎么理解呢！

下面我说一下我的简单理解！

　　　　　　由于TCP协议是一种面向连接的协议，有三次挥手通信确认机制，且数据包没有代销限制，TCP协议确保在通信双方都收到对方确认信息的前提下，才开始为通信的双方传输信息（数据包）！

这样数据包的传输可以得到安全保障！所以简单的理解为安全的！当然一旦，出现网络问题，或者一些其他意外现象造成通信双方的连接出现异常或断开连接，使用TCP是不能传输信息的！

　　　　　　那么相对的！

　　　　　　UDP不是一种面向连接的协议，就是说，在使用UDP协议进行数据交互的时候，彼此可以不连接，通信的一端突然地向另外一端发送数据包，但是对方没有启动接收程序，那么对方当时是收不到数据包的，或者当你发送数据的过程中，突然出现意外断网，停电等等意外现象，都有可能造成对方收不到信息！也就说，你发送的信息对方没收到，同时你也不知道对方有没有收到！这不好！

　　　　 说的有点绕了！现在举一个例子作比较吧！

　　场景：（1）在一个教室里面（例比：一个局域网内！）

　　　　 （2）有小明和小美两个同学（例比：通信的双方！）

　　　　　（3）小明要把一本书交给小美（例比：小明向小美发送一个数据包（书）！）

　　比较：

　　　　 当TCP协议方式：

　　　　　　　　　　（1）tcp面向连接：

　　　　　　　　　　　　　　　　　　小明需要在班里找到小美，走到小美面前，亲手把手交给小美！小美确认小明给他书的是小明，然后接收到小明归还的书！

　　　　当UDP协议方式：

　　　　　　　　　　（1）udp不是面向连接：

　　　　　　　　　　　　　　　　　　小明从座位上站起来，看到小美在的位置方向，可能叫一声“小美”，或者什么也没说，直接把书朝着小美的位置方向！小美可能收到书，也可能没收到！

　　　　例子分析：

　　　　　　　　　　（1）TCP协议下的操作是可以确保小美收到小明归还的书的！

　　　　　　　　　　（2）UDP协议下的操作具有不确定性，可能扔书的时候，小美不知道走开了（接收端没有开启！）

　　　　　　　　　　　　　　　　　　　　　　　　　　　　可能扔书的时候，中间力道不够，没扔到位置处（网络断开，停电，或电脑出现异常等意外现象的发生！）

　　　　　　　　　　　　　　　　　　　　　　　　　　　　可能书在半空中被别人截获了（数据包被截获！）

　　　　　　　　　　　　　这种方式数据的传送不能得到保证！不安全！但是速度快啊！直接扔就行了，不需要再走到小美面前！

2、UDP通讯协议的特点：

　　　　1. 将数据极封装为数据包，面向无连接。
　　　　2. 每个数据包大小限制在64K中
　　　　3.因为无连接，所以不可靠
　　　　4. 因为不需要建立连接，所以速度快
　　　　5.udp 通讯是不分服务端与客户端的，只分发送端与接收端。

　　　　　　比如： 物管的对讲机, 飞Q聊天、 游戏...

3、udp协议下的Socket:

　　　　DatagramSocket(udp插座服务)
　　　　DatagramPacket(数据包类)
　　　　DatagramPacket(buf, length, address, port)
　　　　buf: 发送的数据内容
　　　　length : 发送数据内容的大小。
　　　　address : 发送的目的IP地址对象
　　　　port : 端口号。

4、发送端的使用步骤：
　　　　1. 建立udp的服务。
　　　　2. 准备数据，把数据封装到数据包中发送。 发送端的数据包要带上ip地址与端口号。
　　　　3. 调用udp的服务，发送数据。
　　　　4. 关闭资源。

5、接收端的使用步骤：
　　　　1. 建立udp的服务
　　　　2. 准备空 的数据 包接收数据。
　　　　3. 调用udp的服务接收数据。
　　　　4. 关闭资源

6、UDP协议小案例（1）：发送端和接收端的信息交互！

发送端：

package cn.udp;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
* UDP简单的小例子
* UDP协议下的
*             发送端
*
* @author 小风微灵
*
*/
public class UdpSend {

public static void main(String[] args) throws Exception {

System.out.println("发送端！");
//建立UDP服务插座
DatagramSocket send=new DatagramSocket();

//创建发送包
String content="哈哈哈，我是神！";
DatagramPacket packet=new DatagramPacket(content.getBytes(),
content.getBytes().length,
InetAddress.getLocalHost(),9080);

//发送数据包
send.send(packet);    //发送不是阻塞型的！
System.out.println("数据已发送.....");

//关闭资源
send.close();

}

}

接收端：

package cn.udp;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

/**
* UDP简单的小例子
* UDP协议下的
*             接收端
*
* @author 小风微灵
*
*/
public class UdpAccept {

public static void main(String[] args) throws Exception {

System.out.println("接收端！");
//建立UDP服务插座
DatagramSocket accept=new DatagramSocket(9080);

//创建空的数据包
byte[] buf=new byte[1024];
DatagramPacket packet=new DatagramPacket(buf, buf.length);

//接收数据
accept.receive(packet);    //只有接收是阻型的！

//打印数据
System.out.println("接收到的数据："+new String(buf,0,packet.getLength()));

//关闭
accept.close();

}

}

6、UDP协议小案例（2）：群聊（控制台实现）！

package cn.udp;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
* 模拟聊天室：（群聊）
*     协议支持：UDP
* @author 小风微灵
*
*/

public class UDPChatingRoom {

public static void main(String[] args){
new ChatSend().start(); //启动发送端

new ChatAccep().start();//启动接收端
}
}
/**
* 群聊的接收端
*
*/
class ChatAccep extends Thread {

public void run() {

//插座
try {

DatagramSocket reciver = new DatagramSocket(9999);

byte[] buf = new byte[1024];
DatagramPacket packet = new DatagramPacket(buf, buf.length);

boolean isFlag = true;

while(isFlag){

reciver.receive(packet); //阻塞方法

System.out.println( packet.getAddress().getHostAddress() +":"+new String(buf, 0,packet.getLength()));
}

reciver.close();

} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

}
/**
* 群聊的发送端
*
*/
class ChatSend extends Thread{

public void run() {

try {
DatagramSocket  send = new DatagramSocket();//插座

//得到键盘输入流
BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));

String content = null;

while((content = keyReader.readLine()) != null){

//数据包
DatagramPacket packet = new DatagramPacket(content.getBytes(), content.getBytes().length, InetAddress.getByName("127.0.0.1"), 9999);

send.send(packet);

System.out.println("发送端发送："+content);
}

send.close();

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

}