java_socket服務端和客戶端編程-資料下載頁
2024-08-25 23:39本頁面
【正文】 播來的數(shù)據(jù)。1. 客戶方程序: import .*?！ mport .*?！ mport .*。 public class MulticastClient { public static void main(String args[]) throws IOException { MulticastSocket socket=new MulticastSocket(4446)。 //創(chuàng)建4446端口的廣播套接字 InetAddress address=()。 // (address)?！ ?/使用joinGroup()將廣播套接字綁定到地址上 DatagramPacket packet?！ or(int i=0。i5。i++) { byte[] buf=new byte[256]?！ ?/創(chuàng)建緩沖區(qū) packet=new DatagramPacket(buf,)?！ ?/創(chuàng)建接收數(shù)據(jù)報 (packet)。 //接收 String received=new String(())。 //由接收到的數(shù)據(jù)報得到字節(jié)數(shù)組， //并由此構(gòu)造一個String對象 (Quote of theMoment:+received)。 //打印得到的字符串 } //循環(huán)5次 (address)。 //把廣播套接字從地址上解除綁定 ()。 //關閉廣播套接字 } } 2. 服務器方程序: public class MulticastServer{ public static void main(String args[]) throws { new MulticastServerThread().start()?！ ?/啟動一個服務器線程 } } 3. import .*?！ mport .*。 import .*。 public class MulticastServerThread extends QuoteServerThread //從QuoteServerThread繼承得到新的服務器線程類MulticastServerThread { Private long FIVE_SECOND=5000。 //定義常量，5秒鐘 public MulticastServerThread(String name) throws IOException { super(MulticastServerThread)。 //調(diào)用父類，也就是QuoteServerThread的構(gòu)造函數(shù) } public void run() //重寫父類的線程主體 { while(moreQuotes) { //根據(jù)標志變量判斷是否繼續(xù)循環(huán) try{ byte[] buf=new byte[256]。 //創(chuàng)建緩沖區(qū) String dString=null。 if(in==null) dString=new Date().toString()。 //如果初始化的時候打開文件失敗了， //則使用日期作為要傳送的字符串 else dString=getNextQuote()?！ ?/否則調(diào)用成員函數(shù)從文件中讀出字符串 buf=()?！ ?/把String轉(zhuǎn)換成字節(jié)數(shù)組，以便傳送send it InetAddress group=()。 // DatagramPacket packet=new DatagramPacket(buf,group,4446)。 //根據(jù)緩沖區(qū)，廣播地址，和端口號創(chuàng)建DatagramPacket對象 (packet)。 //發(fā)送該Packet try{ sleep((long)(()*FIVE_SECONDS))?！ ?/隨機等待一段時間，0～5秒之間 }catch(InterruptedException e) { } //異常處理 }catch(IOException e){ //異常處理 ( )。 //打印錯誤?！ oreQuotes=false。 //置結(jié)束循環(huán)標志 } } ( )。 //關閉廣播套接口 } }
范文總結(jié)相關推薦
鄂ICP備17016276號-1