正文

java udp 广播

IP云
IP云V管理员/5 阅读
09/15
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

原文链接: http://blog.csdn.net/yudajun/article/details/8477149

udp 是一种网络通信协议，不需要客户端和服务器端建立连接即可进行通讯功能。相对于Tcp协议它有着tcp用很多优点，例如广播功能。udp的广播功能可以指定特定网段进行广播内容，而无需知道接收者是谁，只有接受者在广播范围内即可接收广播内容。其实基于这个功能可以实现一个局域网群聊室的功能。

udp广播发送有两种形式，

方式一：通过DatagramSocket实现

方式二：通过MulticastSocket 实现

方式一：demo;

1,数据发送端：

  1. import java.io.IOException;
  2. import java.net.DatagramPacket;
  3. import java.net.DatagramSocket;
  4. import java.net.InetAddress;
  5. import java.net.SocketException;
  6. import java.net.UnknownHostException;
  7. public class SendIP {
  8. public static void main(String args[]) {
  9. new SendIP().lanchApp();
  10. }
  11. private void lanchApp(){
  12. SendThread th=new SendThread();
  13. th.start();
  14. }
  15. private class SendThread extends Thread{
  16. @Override
  17. public void run() {
  18. while(true){
  19. try {
  20. Thread.sleep(1000);
  21. } catch (InterruptedException e) {
  22. e.printStackTrace();
  23. }
  24. try {
  25. BroadcastIP();
  26. } catch (Exception e) {
  27. e.printStackTrace();
  28. }
  29. }
  30. }
  31. private void BroadcastIP()throws Exception{
  32. DatagramSocket dgSocket=new DatagramSocket();
  33. byte b[]="你好，这是我发给你的消息".getBytes();
  34. DatagramPacket dgPacket=new DatagramPacket(b,b.length,InetAddress.getByName("255.255.255.255"),8989);
  35. dgSocket.send(dgPacket);
  36. dgSocket.close();
  37. System.out.println("send message is ok.");
  38. }
  39. }
  40. }

2，数据接收端：

  1. import java.net.DatagramPacket;
  2. import java.net.DatagramSocket;
  3. import java.net.SocketException;
  4. import java.util.regex.Matcher;
  5. import java.util.regex.Pattern;
  6. public class SearchIP{
  7. public static void main(String args[])throws Exception{
  8. new SearchIP().lanchApp();
  9. }
  10. private void lanchApp(){
  11. receiveThread th=new receiveThread();
  12. th.start();
  13. }
  14. private class receiveThread extends Thread{
  15. @Override
  16. public void run() {
  17. while(true){
  18. try {
  19. Thread.sleep(1000);
  20. } catch (InterruptedException e) {
  21. e.printStackTrace();
  22. }
  23. try {
  24. receiveIP();
  25. } catch (Exception e) {
  26. e.printStackTrace();
  27. }
  28. }
  29. }
  30. private void receiveIP() throws Exception{
  31. DatagramSocket dgSocket=new DatagramSocket(8989);
  32. byte[] by=new byte[1024];
  33. DatagramPacket packet=new DatagramPacket(by,by.length);
  34. dgSocket.receive(packet);
  35. String str=new String(packet.getData(),0,packet.getLength());
  36. System.out.println("接收到数据大小:"+str.length());
  37. System.out.println("接收到的数据为："+str);
  38. dgSocket.close();
  39. System.out.println("recevied message is ok.");
  40. }
  41. }
  42. }

方式二demo;

1,数据发送端：

  1. import java.io.IOException;
  2. import java.net.DatagramPacket;
  3. import java.net.InetAddress;
  4. import java.net.MulticastSocket;
  5. public class MulBroadcast extends Thread{
  6. String info ="节目预告： 恭喜您中500w彩票了";
  7. int port =9898;
  8. InetAddress address;
  9. MulticastSocket socket;
  10. public MulBroadcast(){
  11. try{
  12. address=InetAddress.getByName("233.0.0.0");
  13. socket=new MulticastSocket(port);
  14. socket.setTimeToLive(1);
  15. socket.joinGroup(address);
  16. }catch(IOException e){
  17. e.printStackTrace();
  18. }
  19. }
  20. @Override   //最简单的方法也就是建立一个线程来运行
  21. public void run(){
  22. while(true){
  23. byte[] data=info.getBytes();
  24. DatagramPacket packet=new DatagramPacket(data,data.length,address,port);
  25. try {
  26. socket.send(packet);
  27. Thread.sleep(3000);
  28. } catch (Exception e) {
  29. e.printStackTrace();
  30. }
  31. System.out.println("消息已发送：");
  32. }
  33. }
  34. public static void main(String[] args){
  35. new MulBroadcast().start();
  36. }
  37. }

2，数据接收端：

  1. import java.io.IOException;
  2. import java.net.DatagramPacket;
  3. import java.net.InetAddress;
  4. import java.net.MulticastSocket;
  5. public class MulReceiverIP extends Thread{
  6. int port=9898;
  7. InetAddress group;
  8. MulticastSocket socket; //socket sends and receives the packet.
  9. DatagramPacket packet;
  10. byte[] buf=new byte[30];// If the message is longer than the packet's length, the message is truncated.
  11. public MulReceiverIP(){
  12. try {
  13. socket=new MulticastSocket(port);
  14. group=InetAddress.getByName("233.0.0.0");
  15. socket.joinGroup(group);    //加入广播组,加入group后,socket发送的数据报,可以被加入到group中的成员接收到。
  16. packet=new DatagramPacket(buf,buf.length);
  17. } catch (IOException e) {
  18. e.printStackTrace();
  19. }
  20. }
  21. @Override
  22. public void run(){
  23. while(true){
  24. try {
  25. socket.receive(packet);
  26. } catch (IOException e) {
  27. e.printStackTrace();
  28. }
  29. //      String message=new String(buf);
  30. String message=new String(packet.getData(),0,packet.getLength());//very important !!
  31. System.out.println("接受消息内容: "+message);
  32. }
  33. }
  34. public static void main(String[] args) {
  35. new MulReceiverIP().start();
  36. }
  37. }