package com.ceshi;

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

public class Fuwuqi implements Runnable {

DatagramSocket ds;

public Fuwuqi(DatagramSocket ds) {
    super();
    this.ds = ds;
}

public void run() {
    while(true){
        try {
            System.out.println("发送验证码");
            BufferedReader bbi = new BufferedReader(new InputStreamReader(
                    System.in));
            String bb = bbi.readLine();

            DatagramPacket dgp = new DatagramPacket(bb.getBytes(),
                    bb.length(), InetAddress.getLocalHost(), 8888);
            ds.send(dgp);
            System.out.println("发送成功");
            byte[] b3 = new byte[1024];
            DatagramPacket dc = new DatagramPacket(b3, b3.length);
            ds.receive(dc);
            String sx = new String(b3).trim();
            if (bb.equals(sx)) {
                System.out.println("注册成功");
            } else {
                System.out.println("注册失败");
            }
            break;

        } catch (Exception e) {

        }
    }
}

public Fuwuqi() {
    super();
}

public static void main(String[] args) throws Exception {
    // TODO Auto-generated method stub
    DatagramSocket ds = new DatagramSocket(9999);
    Fuwuqi ff = new Fuwuqi(ds);

    while (true) {
        byte[] b = new byte[1024];
        DatagramPacket dp = new DatagramPacket(b, b.length);
        ds.receive(dp);
        System.out.println(new String(b).trim() + "用户名输入成功");
        byte[] b1 = new byte[1024];
        DatagramPacket dp1 = new DatagramPacket(b1, b1.length);
        ds.receive(dp1);
        System.out.println(new String(b1).trim() + "密码输入成功");
        break;

    }
    new Thread(ff).start();
}

}