首頁(yè) 考試吧論壇 Exam8視線 考試商城 網(wǎng)絡(luò)課程 模擬考試 考友錄 實(shí)用文檔 求職招聘 論文下載
2011中考 | 2011高考 | 2012考研 | 考研培訓(xùn) | 在職研 | 自學(xué)考試 | 成人高考 | 法律碩士 | MBA考試
MPA考試 | 中科院
四六級(jí) | 職稱(chēng)英語(yǔ) | 商務(wù)英語(yǔ) | 公共英語(yǔ) | 托福 | 雅思 | 專(zhuān)四專(zhuān)八 | 口譯筆譯 | 博思 | GRE GMAT
新概念英語(yǔ) | 成人英語(yǔ)三級(jí) | 申碩英語(yǔ) | 攻碩英語(yǔ) | 職稱(chēng)日語(yǔ) | 日語(yǔ)學(xué)習(xí) | 法語(yǔ) | 德語(yǔ) | 韓語(yǔ)
計(jì)算機(jī)等級(jí)考試 | 軟件水平考試 | 職稱(chēng)計(jì)算機(jī) | 微軟認(rèn)證 | 思科認(rèn)證 | Oracle認(rèn)證 | Linux認(rèn)證
華為認(rèn)證 | Java認(rèn)證
公務(wù)員 | 報(bào)關(guān)員 | 銀行從業(yè)資格 | 證券從業(yè)資格 | 期貨從業(yè)資格 | 司法考試 | 法律顧問(wèn) | 導(dǎo)游資格
報(bào)檢員 | 教師資格 | 社會(huì)工作者 | 外銷(xiāo)員 | 國(guó)際商務(wù)師 | 跟單員 | 單證員 | 物流師 | 價(jià)格鑒證師
人力資源 | 管理咨詢(xún)師考試 | 秘書(shū)資格 | 心理咨詢(xún)師考試 | 出版專(zhuān)業(yè)資格 | 廣告師職業(yè)水平
駕駛員 | 網(wǎng)絡(luò)編輯
衛(wèi)生資格 | 執(zhí)業(yè)醫(yī)師 | 執(zhí)業(yè)藥師 | 執(zhí)業(yè)護(hù)士
會(huì)計(jì)從業(yè)資格考試會(huì)計(jì)證) | 經(jīng)濟(jì)師 | 會(huì)計(jì)職稱(chēng) | 注冊(cè)會(huì)計(jì)師 | 審計(jì)師 | 注冊(cè)稅務(wù)師
注冊(cè)資產(chǎn)評(píng)估師 | 高級(jí)會(huì)計(jì)師 | ACCA | 統(tǒng)計(jì)師 | 精算師 | 理財(cái)規(guī)劃師 | 國(guó)際內(nèi)審師
一級(jí)建造師 | 二級(jí)建造師 | 造價(jià)工程師 | 造價(jià)員 | 咨詢(xún)工程師 | 監(jiān)理工程師 | 安全工程師
質(zhì)量工程師 | 物業(yè)管理師 | 招標(biāo)師 | 結(jié)構(gòu)工程師 | 建筑師 | 房地產(chǎn)估價(jià)師 | 土地估價(jià)師 | 巖土師
設(shè)備監(jiān)理師 | 房地產(chǎn)經(jīng)紀(jì)人 | 投資項(xiàng)目管理師 | 土地登記代理人 | 環(huán)境影響評(píng)價(jià)師 | 環(huán)保工程師
城市規(guī)劃師 | 公路監(jiān)理師 | 公路造價(jià)師 | 安全評(píng)價(jià)師 | 電氣工程師 | 注冊(cè)測(cè)繪師 | 注冊(cè)計(jì)量師
繽紛校園 | 實(shí)用文檔 | 英語(yǔ)學(xué)習(xí) | 作文大全 | 求職招聘 | 論文下載 | 訪談 | 游戲

2011年計(jì)算機(jī)等考二級(jí)JAVA學(xué)習(xí)精華整理(49)

考試吧整理了2011年計(jì)算機(jī)的等考二級(jí)JAVA學(xué)習(xí)精華,幫助考生備考。

  第三步 實(shí)現(xiàn)信息共享:在Socket上的實(shí)時(shí)交流

  網(wǎng)絡(luò)的偉大之一也是信息共享,Server可以主動(dòng)向所有Client廣播消息,同時(shí)Client也可以向其它Client發(fā)布消息。下面看看如何開(kāi)發(fā)一個(gè)可以實(shí)時(shí)傳遞消息的程序。

  設(shè)計(jì)原理:

  服務(wù)器端接受客戶(hù)端的連接請(qǐng)求,同時(shí)啟動(dòng)一個(gè)線程處理這個(gè)連接,線程不停的讀取客戶(hù)端輸入,然后把輸入加入隊(duì)列中,等候處理。在線程啟動(dòng)的同時(shí)將線程加入隊(duì)列中,以便在需要的時(shí)候定位和取出。

  {源碼}

  import java.io.*;

  import java.net.*;

  import java.util.*;

  import java.lang.*;

  public class Server extends ServerSocket

  {

  private static ArrayList User_List = new ArrayList();

  private static ArrayList Threader = new ArrayList();

  private static LinkedList Message_Array = new LinkedList();

  private static int Thread_Counter = 0;

  private static boolean isClear = true;

  protected static final int SERVER_PORT = 10000;

  protected FileOutputStream LOG_FILE = new FileOutputStream("d:/connect.log", true);

  public Server() throws FileNotFoundException, IOException

  {

  super(SERVER_PORT);

  new Broadcast();

  //append connection log

  Calendar now = Calendar.getInstance();

  String str = "[" + now.getTime().toString() + "] Accepted a connection\015\012";

  byte[] tmp = str.getBytes();

  LOG_FILE.write(tmp);

  try

  {

  while (true)

  {

  Socket socket = accept();

  new CreateServerThread(socket);

  }

  }

  finally

  {

  close();

  }

  }

  public static void main(String[] args) throws IOException

  {

  new Server();

  }

  //--- Broadcast

  class Broadcast extends Thread

  {

  public Broadcast()

  {

  start();

  }

  public void run()

  {

  while (true)

  {

  if (!isClear)

  {

  String tmp = (String)Message_Array.getFirst();

  for (int i = 0; i < Threader.size(); i++)

  {

  CreateServerThread client = (CreateServerThread)Threader.get(i);

  client.sendMessage(tmp);

  }

  Message_Array.removeFirst();

  isClear = Message_Array.size() > 0 ? false : true;

  }

  }

  }

  }

  //--- CreateServerThread

  class CreateServerThread extends Thread

  {

  private Socket client;

  private BufferedReader in;

  private PrintWriter out;

  private String Username;

  public CreateServerThread(Socket s) throws IOException

  {

  client = s;

  in = new BufferedReader(new InputStreamReader(client.getInputStream()));

  out = new PrintWriter(client.getOutputStream(), true);

  out.println("--- Welcome to this chatroom ---");

  out.println("Input your nickname:");

  start();

  }

  public void sendMessage(String msg)

  {

  out.println(msg);

  }

  public void run()

  {

  try

  {

  int flag = 0;

  Thread_Counter++;

  String line = in.readLine();

  while (!line.equals("bye"))

  {

  if (line.equals("l"))

  {

  out.println(listOnlineUsers());

  line = in.readLine();

  continue;

  }

  if (flag++ == 0)

  {

  Username = line;

  User_List.add(Username);

  out.println(listOnlineUsers());

  Threader.add(this);

  pushMessage("[< " + Username + " come on in >]");

  }

  else

  {

  pushMessage("<" + Username + ">" + line);

  }

  line = in.readLine();

  }

  out.println("--- See you, bye! ---");

  client.close();

  }

  catch (IOException e)

  {}

  finally

  {

  try

  {

  client.close();

  }

  catch (IOException e)

  {}

  Thread_Counter--;

  Threader.remove(this);

  User_List.remove(Username);

  pushMessage("[< " + Username + " left>]");

  }

  }

  private String listOnlineUsers()

  {

  String s ="-+- online list -+-\015\012";

  for (int i = 0; i < User_List.size(); i++)

  {

  s += "[" + User_List.get(i) + "]\015\012";

  }

  s += "-+---------------------+-";

  return s;

  }

  private void pushMessage(String msg)

  {

  Message_Array.addLast(msg);

  isClear = false;

  }

  }

  }

 

screen.width-333)this.width=screen.width-333;" border=0>

  這就是程序運(yùn)行后,多用戶(hù)登陸并且輸入信息后的屏幕。實(shí)現(xiàn)了信息的實(shí)時(shí)廣播。用戶(hù)輸入"l"就可以列出在線人員表。

  相關(guān)推薦:計(jì)算機(jī)等級(jí)考試二級(jí)Java經(jīng)典算法大全匯總

       2010年9月計(jì)算機(jī)等級(jí)考試成績(jī)查詢(xún)時(shí)間匯總

        2011計(jì)算機(jī)等級(jí)考試二級(jí)JAVA學(xué)習(xí)精華匯總

文章搜索
版權(quán)聲明:如果計(jì)算機(jī)等級(jí)考試網(wǎng)所轉(zhuǎn)載內(nèi)容不慎侵犯了您的權(quán)益,請(qǐng)與我們聯(lián)系800@exam8.com,我們將會(huì)及時(shí)處理。如轉(zhuǎn)載本計(jì)算機(jī)等級(jí)考試網(wǎng)內(nèi)容,請(qǐng)注明出處。