package 网络编程_客户咨询;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.net.UnknownHostException;

import java.util.Scanner;

public class sender {

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

        // TODO Auto-generated method stub

        Scanner input = new Scanner(System.in);

        do{

        InetAddress ia = null;

        ia = InetAddress.getByName("localhost");

        System.out.println("input a message:");

        String mes = input.next();

        DatagramPacket dp = new DatagramPacket(mes.getBytes(),mes.length(),ia,8806);

        DatagramSocket ds = new DatagramSocket();

        ds.send(dp);

        System.out.println("ok!sending..");

    //-------------接受------

        byte[] buf= new byte[1024];

        DatagramPacket dp1 = new DatagramPacket(buf, 1024);

        DatagramSocket ds1 = new DatagramSocket(8806);

        ds1.receive(dp1);

        String mee = new String(dp1.getData(),0,dp1.getLength());

        System.out.println(mee);

        System.out.println("receive session over!");

        ds.close();

        }while(true);

    }

}

package 网络编程_客户咨询;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.util.Scanner;

public class receiver {

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

        // TODO Auto-generated method stub

        Scanner input = new Scanner(System.in);

        do{

        System.out.println("Session begin:");

        byte[] buf= new byte[1024];

        DatagramPacket dp = new DatagramPacket(buf, 1024);

        DatagramSocket ds = new DatagramSocket(8806);

        ds.receive(dp);

        String mee = new String(dp.getData(),0,dp.getLength());

        System.out.println(mee);

        System.out.println("receive session over!");

//-------------------------发送回复---------------------

        System.out.println("please reply:");

        String reply = input.nextLine();

        InetAddress ia = null;

        ia = InetAddress.getByName("localhost");

        DatagramPacket dpr = new DatagramPacket(reply.getBytes(),reply.length(),ia,8806);

        ds.send(dpr);

        ds.close();

        }while(true);

    }

}

版权声明：本文为博主原创文章，未经博主允许不得转载。