总结java - socket编程

//得到230.0.0.1的地址信息 socket.joinGroup(address);

//使用joinGroup()将广播套接字绑定到地址上 DatagramPacket packet; for(int i=0;i<5;i++) {

byte[] buf=new byte[256]; //创建缓冲区

packet=new DatagramPacket(buf,buf.length); //创建接收数据报

socket.receive(packet); //接收

String received=new String(packet.getData()); //由接收到的数据报得到字节数组， //并由此构造一个String对象

System.out.println(\ //打印得到的字符串 } //循环5次

socket.leaveGroup(address); //把广播套接字从地址上解除绑定 socket.close(); //关闭广播套接字 } }

2. 服务器方程序:MulticastServer.java public class MulticastServer{

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

new MulticastServerThread().start(); //启动一个服务器线程 } }

3. 程序MulticastServerThread.java import java.io.*; import java.net.*; import java.util.*;

public class MulticastServerThread extends QuoteServerThread

//从QuoteServerThread继承得到新的服务器线程类MulticastServerThread {

Private long FIVE_SECOND=5000; //定义常量，5秒钟 public MulticastServerThread(String name) throws IOException {

super(\

//调用父类，也就是QuoteServerThread的构造函数 }

public void run() //重写父类的线程主体 {

while(moreQuotes) {

//根据标志变量判断是否继续循环 try{

byte[] buf=new byte[256]; //创建缓冲区 String dString=null;

if(in==null) dString=new Date().toString(); //如果初始化的时候打开文件失败了， //则使用日期作为要传送的字符串 else dString=getNextQuote();

//否则调用成员函数从文件中读出字符串 buf=dString.getByte();

//把String转换成字节数组，以便传送send it

InetAddress group=InetAddress.getByName(\ //得到230.0.0.1的地址信息 DatagramPacket packet=new DatagramPacket(buf,buf.length,group,4446);

//根据缓冲区，广播地址，和端口号创建DatagramPacket对象 socket.send(packet); //发送该Packet try{

sleep((long)(Math.random()*FIVE_SECONDS)); //随机等待一段时间，0～5秒之间 }catch(InterruptedException e) { } //异常处理 }catch(IOException e){ //异常处理 e.printStackTrace( ); //打印错误栈 moreQuotes=false; //置结束循环标志 } }

socket.close( ); //关闭广播套接口 } }