-
实现的效果如下
chatDemo udp和tcp的特点
udp
1、将数据封装在数据包中，不需要建立连接，面向无连接
2、每个数据包的大小限制在64k内
3、因为无连接，是不可靠协议
4、速度快
tpc
1、建立连接，形成传输数据的通道
2、在连接中进行大数据量传输
3、通过三次握手完成连接，是可靠协议
4、必须建立连接，效率会稍低
- 以下是通过udp进行通讯的，废话不多说，直接上代码
import java.net.*;
import java.io.*;
/*
聊天程序
有发送端和接收端
采用多线程，一个控制发送，一个控制接收
并采用键盘录入的方式
这里的异常我就直接抛了
*/
class ChatDemo{
public static void main(String[] args) throws Exception{
//创建udp服务
DatagramSocket sendSocket = new DatagramSocket();
DatagramSocket receSocket = new DatagramSocket(10002);
//开启线程
new Thread(new Send(sendSocket)).start();
new Thread(new Rece(receSocket)).start();
}
}
/*
发送端
实现步骤：
1、创建udp socket 服务
2、定义数据包，并将数据封装到数据包中。
3、通过socket服务的发送方法，将数据发送出去。
4、关闭资源
*/
class Send implements Runnable{
private DatagramSocket ds;
public Send(DatagramSocket ds){
this.ds = ds;
}
public void run(){
try{
//键盘录入
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line = bufr.readLine()) != null){//这里的bufr.readLine()其实是一个阻塞方法，等待输入结束后才继续执行下面的代码
if("886".equals(line)){
break;
}
//获取到键盘录入数据，定义数据包，并将数据封装到数据包中，指定要发送到哪台主机的哪个端口上
//这里只用本机做测试，所以指定的ip地址是本地的，端口随便起，不要超过指定的大小即可
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.3.107"),10002);
//发送数据包
ds.send(dp);
}
}catch(Exception e){
throw new RuntimeException("send client error");
}finally{
if(ds != null){
try{
//关闭资源
ds.close();
}catch(Exception e){}
}
}
}
}
/*
接收端
实现步骤：
1、创建udp socket ,建立端点。通常会监听一个端口，其实就是给这个接收网络应用程序定义数字标识，
为了方便明确哪些数据过来该应用程序可以处理
2、定义数据包，因为要存储接收到的字节数据，
因为数据包中有更多功能提取字节数据中的不同数据信息。
3、通过socket服务的receive方法将收到的数据存入已定义好的数据包中。
4、通过数据包对象的特有方法，将这些不同的数据获取到并打印在控制台。
5、关闭资源
*/
class Rece implements Runnable{
private DatagramSocket ds;
public Rece(DatagramSocket ds){
this.ds = ds;
}
public void run(){
try{
while(true){
//定义个数组存储接收到的数据
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);
//通过receive方法将收到的数据存入数据包中
//这里的receive是一个阻塞方法，会一直停在这，直到有数据来了才会被唤醒继续执行下面代码
ds.receive(dp);
//通过数据包的方法获取其中的数据
String ip = dp.getAddress().getHostAddress();
String data = new String(dp.getData(),0,dp.getLength());
//这里只打印ip和data
System.out.println(ip + "-----" + data);
}
}catch(Exception e){
throw new RuntimeException("receive server error");
}finally{
if(ds != null){
try{
ds.close();
}catch(Exception e){}
}
}
}
}
- 如何运行
1、将上面的代码复制粘贴到你的文本编辑器，并以ChatDemo.java命名，存到你想存的文件夹当中
2、配置好jdk和相对应的环境变量
3、调出cmd控制台，cd到ChatDemo.java文件目录下
4、输入"javac ChatDemo.java"进行编译
5、编译通过后再输入"java ChatDemo"运行
6、就可以看到上图中的界面了，可以随便测试了。
- 获取本机ip地址
因为是在自己的机器运行，所以你要修改代码中的ip地址。
获取本机ip地址方式：通过cmd控制台，输入"ipconfig"按回车，你看到的ipv4就是你的本机代码了，右键选中按回车进行复制即可。
用到的api,参考android官方文档
DatagramSocket
DatagramPacket
InetAddress由于代码中的解释已经很清楚了，在这里就不做解释了。后期会出个Tcp的
