`

简单易懂的组播（课本）

    博客分类：
  • java
SocketthreadSwing.net 
阅读更多

1，不断重复广播一则新闻。

Code:
  1. packageMulSocket.fromBook;
  3. importjava.net.*;
  5. publicclassBroadCastextendsThread{
  6. Strings="今天天气好晴朗，处处好风光！";
  7. intport=5858;//组播的端口
  8. InetAddressgroup=null;//组播组
  9. MulticastSocketsocket=null;//多点广播套接字
  11. BroadCast(){
  12. try{
  13. group=InetAddress.getByName("239.255.8.0");//设置组播组为239.255.8.0
  14. socket=newMulticastSocket(port);//多点广播套接字将在port端口广播
  15. socket.setTimeToLive(0);//多点广播套接字发送数据报范围为本地网络
  16. socket.joinGroup(group);
  17. //加入组播组,加入group后，socket发送的数据报可以被加入到group中的成员接收到
  18. }catch(Exceptione){
  19. }
  20. }
  22. publicvoidrun(){
  23. while(true){
  24. try{
  25. DatagramPacketpacket=null;//待广播的数据报
  26. bytedata[]=s.getBytes();
  27. packet=newDatagramPacket(data,data.length,group,port);
  28. System.out.println(newString(data));
  29. socket.send(packet);//广播数据报
  30. sleep(2000);
  31. }catch(Exceptione){
  32. System.out.println(e.toString());
  33. break;
  34. }
  35. }
  36. }
  38. publicstaticvoidmain(Stringargs[]){
  39. newBroadCast().start();
  40. }
  41. }

2加入组播组，接收广播数据

Code:
  1. packageMulSocket.fromBook;
  3. importjava.net.*;
  4. importjava.awt.*;
  5. importjava.awt.event.*;
  6. importjavax.swing.*;
  8. publicclassReceiveextendsJFrameimplementsRunnable,ActionListener{
  9. privatestaticfinallongserialVersionUID=1L;
  10. intport;//组播的端口
  11. InetAddressgroup=null;//组播组的地址
  12. MulticastSocketsocket=null;//多点广播套接字
  14. JButtonstartReceive,stopReceive;
  15. JTextAreashowArea;
  16. Threadthread;//负责接收信息的线程
  17. booleanstop=false;
  19. publicReceive(){
  20. super("定时接收信息");
  21. thread=newThread(this);
  22. startReceive=newJButton("开始接收");
  23. stopReceive=newJButton("停止接收");
  24. startReceive.addActionListener(this);
  25. stopReceive.addActionListener(this);
  26. showArea=newJTextArea(10,10);
  27. JPanelnorth=newJPanel();
  28. north.add(startReceive);
  29. north.add(stopReceive);
  30. Containercon=getContentPane();
  31. con.add(north,BorderLayout.NORTH);
  32. con.add(newJScrollPane(showArea),BorderLayout.CENTER);
  33. port=5858;
  34. try{
  35. //初始化一气呵成
  36. group=InetAddress.getByName("239.255.8.0");
  37. socket=newMulticastSocket(port);
  38. socket.joinGroup(group);
  39. }catch(Exceptione){
  40. }
  41. setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  42. setSize(320,300);
  43. validate();
  44. setVisible(true);
  45. }
  47. publicvoidactionPerformed(ActionEvente){
  48. if(e.getSource()==startReceive){
  49. if(!(thread.isAlive())){
  50. thread=newThread(this);
  51. stop=false;
  52. }
  53. try{
  54. thread.start();
  55. }catch(Exceptionee){
  56. }
  57. }
  58. if(e.getSource()==stopReceive){
  59. stop=true;
  60. }
  61. }
  63. publicvoidrun(){
  64. while(true){
  65. bytedata[]=newbyte[8192];
  66. DatagramPacketpacket=null;
  67. packet=newDatagramPacket(data,data.length,group,port);
  68. try{
  69. socket.receive(packet);
  70. Stringmessage=newString(packet.getData(),0,packet
  71. .getLength());
  72. showArea.append("/n"+message);
  73. showArea.setCaretPosition(showArea.getText().length());
  74. }catch(Exceptione){
  75. }
  76. if(stop==true)
  77. break;
  78. }
  79. }
  81. publicstaticvoidmain(Stringargs[]){
  82. newReceive();
  83. }
  84. }

思路明确简单易懂。

分享到：
| 搭建CVS服务器和客户端
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics