网络编程-udp通信

package com.it.www;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

class Send implements Runnable{

private DatagramSocket datagramSocket ;
Send(DatagramSocket datagramSocket){
this.datagramSocket = datagramSocket;
}
@Override
public void run() {
// TODO Auto-generated method stub
try {

//创建一个字符输入流
InputStreamReader in = new InputStreamReader(System.in);

//创建一个包装类，把字符流放到缓存中
BufferedReader buff  = new BufferedReader(in);

String line = null;
while((line = buff.readLine()) != null)
{
if("885".equals(line))
break;

byte[] dataLine = line.getBytes();// 字符串数据转化为字节数据

DatagramPacket datagramPacket =
new DatagramPacket(dataLine, dataLine.length, InetAddress.getByName("127.0.0.1"), 10001);
datagramSocket.send(datagramPacket);
}
datagramSocket.close();

} catch (Exception e) {
// TODO: handle exception
throw new RuntimeException("发送端失败");
}
}

}

class Receive implements Runnable{

DatagramSocket datagramSocket ;
public Receive(DatagramSocket datagramSocket) {
// TODO Auto-generated constructor stub
this.datagramSocket = datagramSocket;
}
@Override
public void run() {
// TODO Auto-generated method stub
try {

while(true)
{
byte[] data = new byte[1024];

//声明一个字节包,用来存放接收对方的数据
DatagramPacket datagramPacket =
new DatagramPacket(data, data.length);

//通古socket服务将收到的数据存到数据包中
datagramSocket.receive(datagramPacket);

//获取对方的主机地址
System.out.println(datagramPacket.getAddress().getHostAddress());

//获取对方发送的数据
String dataString =
new String(datagramPacket.getData(),0,datagramPacket.getLength());
System.out.println("dataString ="+dataString);
}

} catch (Exception e) {
// TODO: handle exception
throw new RuntimeException("接收失败");
}
}

}

public class UdpCommunicate{

public static void main(String[] args) throws Exception {
DatagramSocket sendDatagramSocket = new DatagramSocket();
DatagramSocket receivedDatagramSocket = new DatagramSocket(10001);

new Thread(new Send(sendDatagramSocket)).start();
new Thread(new Receive(receivedDatagramSocket)).start();
}
}