日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Java多客戶端通信服務(wù)端代碼介紹

Java 多客戶端通信在很多人看來是一項(xiàng)很繁瑣的工作，其實(shí)我們?cè)诰帉懘a的時(shí)候只要是注意留心Java 多客戶端通信的源代碼就能發(fā)現(xiàn)，我們認(rèn)為枯燥的東西其實(shí)都很簡單。

創(chuàng)新互聯(lián)成立于2013年，先為錫山等服務(wù)建站，錫山等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為錫山企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

來看服務(wù)端的代碼:

 
 
 
    
  
  
  
  1. import java.net.*;  
    2. 
  
  
  
  2. import java.io.*;  
    3. 
  
  
  
  3. import java.util.*;  
    4. 
  
  
  
  4. public class Jserver3 {  
    5. 
  
  
  
  5. private ServerSocket server;  
    6. 
  
  
  
  6. List sManager = new ArrayList();  
    7. 
  
  
  
  7. public Jserver3(){}  
    8. 
  
  
  
  8. void startServer()　//運(yùn)行服務(wù)器  
    9. 
  
  
  
  9. {  
    10. 
  
  
  
  10. try  
    11. 
  
  
  
  11. {  
    12. 
  
  
  
  12. server=new ServerSocket(719);  
    13. 
  
  
  
  13. System.out.println("服務(wù)器套接字已創(chuàng)建成功！");  
    14. 
  
  
  
  14. while(true)  
    15. 
  
  
  
  15. {  
    16. 
  
  
  
  16. Socket socket=server.accept();  
    17. 
  
  
  
  17. System.out.println("已經(jīng)與客戶端連接");  
    18. 
  
  
  
  18. new J_Thread(socket).start();  
    19. 
  
  
  
  19. sManager.add(socket);  
    20. 
  
  
  
  20. System.out.println("當(dāng)前客戶端連結(jié)數(shù)："+sManager.size());  
    21. 
  
  
  
  21. }  
    22. 
  
  
  
  22. }catch(Exception e){}finally  
    23. 
  
  
  
  23. {  
    24. 
  
  
  
  24. try  
    25. 
  
  
  
  25. {  
    26. 
  
  
  
  26. server.close();  
    27. 
  
  
  
  27. }catch(Exception e){}  
    28. 
  
  
  
  28. }  
    29. 
  
  
  
  29. }  
    30. 
  
  
  
  30. public static void main(String[] args) {  
    31. 
  
  
  
  31. Jserver3 server=new Jserver3();  
    32. 
  
  
  
  32. server.startServer();  
    33. 
  
  
  
  33. }  
    34. 
  
  
  
  34. class J_Thread extends Thread　　//與客戶端進(jìn)行通信的線程類  
    35. 
  
  
  
  35. {  
    36. 
  
  
  
  36. Socket socket;　　 //套接字引用變量  
    37. 
  
  
  
  37. private DataInputStream reader;　　 //套接字輸入流  
    38. 
  
  
  
  38. private DataOutputStream writer;　 //套接字輸出流  
    39. 
  
  
  
  39. J_Thread(Socket socket)　　 //構(gòu)造函數(shù)  
    40. 
  
  
  
  40. {  
    41. 
  
  
  
  41. this.socket=socket;  
    42. 
  
  
  
  42. }  
    43. 
  
  
  
  43. public void run()  
    44. 
  
  
  
  44. {  
    45. 
  
  
  
  45. try  
    46. 
  
  
  
  46. {  
    47. 
  
  
  
  47. reader=new DataInputStream(socket.getInputStream());//獲取套接字的輸入流  
    48. 
  
  
  
  48. writer=new DataOutputStream(socket.getOutputStream());//獲取套接字的輸出流  
    49. 
  
  
  
  49. String msg;  
    50. 
  
  
  
  50. while((msg=reader.readUTF())!=null)//如果收到客戶端發(fā)來的數(shù)據(jù)  
    51. 
  
  
  
  51. {  
    52. 
  
  
  
  52. //向客戶端發(fā)送信息  
    53. 
  
  
  
  53. writer.writeUTF("您的情書已經(jīng)收到");  
    54. 
  
  
  
  54. writer.flush();  
    55. 
  
  
  
  55. System.out.println("來自客戶端："+msg);  
    56. 
  
  
  
  56. }  
    57. 
  
  
  
  57. }catch(Exception e){}finally  
    58. 
  
  
  
  58. {  
    59. 
  
  
  
  59. try  
    60. 
  
  
  
  60. {  
    61. 
  
  
  
  61. sManager.remove(socket); 　//刪除套接字  
    62. 
  
  
  
  62. //關(guān)閉輸入輸出流及套接字  
    63. 
  
  
  
  63. if(reader!=null)reader.close();  
    64. 
  
  
  
  64. if(writer!=null)writer.close();  
    65. 
  
  
  
  65. if(socket!=null)socket.close();  
    66. 
  
  
  
  66. reader=null;  
    67. 
  
  
  
  67. writer=null;  
    68. 
  
  
  
  68. socket=null;  
    69. 
  
  
  
  69. System.out.println("客戶端離開");//向屏幕輸出相關(guān)信息  
    70. 
  
  
  
  70. System.out.println("當(dāng)前客戶端的連接數(shù)："+sManager.size());  
    71. 
  
  
  
  71. }catch(Exception e){}  
    72. 
  
  
  
  72. }  
    73. 
  
  
  
  73. }  
    74. 
  
  
  
  74. }  
    75. 
  
  
  
  75. }  
    76. 
  
  
  
  76. import java.net.*; 
    77. 
  
  
  
  77. import java.io.*; 
    78. 
  
  
  
  78. import java.util.*; 
    79. 
  
  
  
  79. public class Jserver3 { 
    80. 
  
  
  
  80. private ServerSocket server; 
    81. 
  
  
  
  81. List sManager = new ArrayList(); 
    82. 
  
  
  
  82. public Jserver3(){} 
    83. 
  
  
  
  83. void startServer()　//運(yùn)行服務(wù)器 
    84. 
  
  
  
  84. { 
    85. 
  
  
  
  85. try 
    86. 
  
  
  
  86. { 
    87. 
  
  
  
  87. server=new ServerSocket(719); 
    88. 
  
  
  
  88. System.out.println("服務(wù)器套接字已創(chuàng)建成功！"); 
    89. 
  
  
  
  89. while(true) 
    90. 
  
  
  
  90. { 
    91. 
  
  
  
  91. Socket socket=server.accept(); 
    92. 
  
  
  
  92. System.out.println("已經(jīng)與客戶端連接"); 
    93. 
  
  
  
  93. new J_Thread(socket).start(); 
    94. 
  
  
  
  94. sManager.add(socket); 
    95. 
  
  
  
  95. System.out.println("當(dāng)前客戶端連結(jié)數(shù)："+sManager.size()); 
    96. 
  
  
  
  96. } 
    97. 
  
  
  
  97. }catch(Exception e){}finally 
    98. 
  
  
  
  98. { 
    99. 
  
  
  
  99. try 
    100. 
  
  
  
  100. { 
    101. 
  
  
  
  101. server.close(); 
    102. 
  
  
  
  102. }catch(Exception e){} 
    103. 
  
  
  
  103. } 
    104. 
  
  
  
  104. } 
    105. 
  
  
  
  105. public static void main(String[] args) { 
    106. 
  
  
  
  106. Jserver3 server=new Jserver3(); 
    107. 
  
  
  
  107. server.startServer(); 
    108. 
  
  
  
  108. } 
    109. 
  
  
  
  109. class J_Thread extends Thread　　//與客戶端進(jìn)行通信的線程類 
    110. 
  
  
  
  110. { 
    111. 
  
  
  
  111. Socket socket;　　 //套接字引用變量 
    112. 
  
  
  
  112. private DataInputStream reader;　　 //套接字輸入流 
    113. 
  
  
  
  113. private DataOutputStream writer;　 //套接字輸出流 
    114. 
  
  
  
  114. J_Thread(Socket socket)　　 //構(gòu)造函數(shù) 
    115. 
  
  
  
  115. { 
    116. 
  
  
  
  116. this.socket=socket; 
    117. 
  
  
  
  117. } 
    118. 
  
  
  
  118. public void run() 
    119. 
  
  
  
  119. { 
    120. 
  
  
  
  120. try 
    121. 
  
  
  
  121. { 
    122. 
  
  
  
  122. reader=new DataInputStream(socket.getInputStream());//獲取套接字的輸入流 
    123. 
  
  
  
  123. writer=new DataOutputStream(socket.getOutputStream());//獲取套接字的輸出流 
    124. 
  
  
  
  124. String msg; 
    125. 
  
  
  
  125. while((msg=reader.readUTF())!=null)//如果收到客戶端發(fā)來的數(shù)據(jù) 
    126. 
  
  
  
  126. { 
    127. 
  
  
  
  127. //向客戶端發(fā)送信息 
    128. 
  
  
  
  128. writer.writeUTF("您的情書已經(jīng)收到"); 
    129. 
  
  
  
  129. writer.flush(); 
    130. 
  
  
  
  130. System.out.println("來自客戶端："+msg); 
    131. 
  
  
  
  131. } 
    132. 
  
  
  
  132. }catch(Exception e){}finally 
    133. 
  
  
  
  133. { 
    134. 
  
  
  
  134. try 
    135. 
  
  
  
  135. { 
    136. 
  
  
  
  136. sManager.remove(socket); 　//刪除套接字 
    137. 
  
  
  
  137. //關(guān)閉輸入輸出流及套接字 
    138. 
  
  
  
  138. if(reader!=null)reader.close(); 
    139. 
  
  
  
  139. if(writer!=null)writer.close(); 
    140. 
  
  
  
  140. if(socket!=null)socket.close(); 
    141. 
  
  
  
  141. reader=null; 
    142. 
  
  
  
  142. writer=null; 
    143. 
  
  
  
  143. socket=null; 
    144. 
  
  
  
  144. System.out.println("客戶端離開");//向屏幕輸出相關(guān)信息 
    145. 
  
  
  
  145. System.out.println("當(dāng)前客戶端的連接數(shù)："+sManager.size()); 
    146. 
  
  
  
  146. }catch(Exception e){} 
    147. 
  
  
  
  147. } 
    148. 
  
  
  
  148. } 
    149. 
  
  
  
  149. } 
    150. 
  
  
  
  150. }
    151.

嘎嘎 在這段代碼里，服務(wù)端MM為每一個(gè)連接的客戶端GG分配一個(gè)單獨(dú)的線程，而每一個(gè)線程里都持有對(duì)應(yīng)的客戶端GG的Java 多客戶端通信對(duì)象。SO，通過這些多線程，服務(wù)端MM就練就了一心N用的功力，可以同時(shí)接受N個(gè)客戶端GG發(fā)來的情書了（，真的太賤了。。。。）

客戶端的代碼和上面的客戶端代碼一模一樣的，這里就不多說啦！


當(dāng)前文章：Java多客戶端通信服務(wù)端代碼介紹
文章來源：http://m.5511xx.com/article/cdjcpij.html