java实现基于UDP协议的聊天小程序操作

package com.offcn.second;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.util.Scanner;

public class MyQQ {

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

         DatagramSocket ds = new DatagramSocket();

         Scanner sc= new Scanner(System.in);

         while ( true ){

             //发送消息

             System.out.print( "My:" );

             //输入发送信息

             String smsg = sc.nextLine();

             //byte[] sbs = smsg.getBytes();

             //int slen = sbs.length;

             //创建数据包

             DatagramPacket sdp = new DatagramPacket(smsg.getBytes(), //数据转为byte数组

                     smsg.getBytes().length, //数据长度

                     InetAddress.getLocalHost(), //接收端端口号

                     9999 ); //接收端，端口号

             //发送

             ds.send(sdp);

             //接收消息

             //创建接收数据的数据包

             DatagramPacket rdp = new DatagramPacket( new byte [ 1024 ], 1024 );

             //接收数据

             ds.receive(rdp);

             //将接收的数据转为字符串

             String rmsg = new String(rdp.getData(), 0 ,rdp.getLength());

             //打印输出

             System.out.println( "His:" +rmsg);

         }

     }

}

package com.offcn.second;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.util.Scanner;

public class HisQQ {

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

         DatagramSocket ds = new DatagramSocket( 9999 );

         Scanner sc = new Scanner(System.in);

         while ( true ){

             //创建接收数据的数据包

             DatagramPacket rdp = new DatagramPacket( new byte [ 1024 ], 1024 );

             ds.receive(rdp);

             //将接收的数据转换为字符串

             String rmsg = new String(rdp.getData(), 0 ,rdp.getLength());

             //输出接收到的信息

             System.out.println( "His:" +rmsg);

             //给对方回消息

             //输入发送的数据

             System.out.print( "My:" );

             String smsg = sc.nextLine();

             //创建发送数据的数据包

             DatagramPacket sdp = new DatagramPacket(smsg.getBytes(),

                     smsg.getBytes().length,

                     rdp.getAddress(),

                     rdp.getPort());

             ds.send(sdp);

         }

     }

}