JavaSocket通信如何进行通用服务器代码编写

Java Socket通信有很多的时候需要我们不断的学习。方面效率虽然不及C与C++但它以灵活语言优势，为大家广为使用。 本文就对在使用java做通信方面程序时候应改注意问题做以说明。

1.长连接、短链接只是针对客户端而言，服务器无所谓长、短；

2.无论同步或者异步通信，发送之后务必要又响应回复，确认收到，负责进行一定范围内重发，例如重发三次；

3.长连接服务器与客户端之间务必需要心跳探测，由客户端主动发起；

4.短连接服务器通用代码：

 
 
 
    
  
  
  
  1. package com.biesan.sms.gate.unioncom.communication; 
    2. 
  
  
  
  2. import com.biesan.commons.Constants; 
    3. 
  
  
  
  3. import com.biesan.commons.util.CodeUtil; 
    4. 
  
  
  
  4. import com.biesan.sms.gate.unioncom.data.*; 
    5. 
  
  
  
  5. import com.biesan.sms.gate.unioncom.util.GateInfo; 
    6. 
  
  
  
  6. import java.net.*; 
    7. 
  
  
  
  7. import java.io.*; 
    8. 
  
  
  
  8. import java.util.*; 
    9. 
  
  
  
  9. import org.apache.log4j.*; 
    10. 
  
  
  
  10. import spApi.*; 
    11. 
  
  
  
  11. public class UnioncomDeliver extends Thread { 
    12. 
  
  
  
  12. // stop flag 
    13. 
  
  
  
  13. private boolean unInterrupt = true; 
    14. 
  
  
  
  14. private boolean unErr = true; 
    15. 
  
  
  
  15. //private boolean closeSocketFlag = false; 
    16. 
  
  
  
  16. // server socket 
    17. 
  
  
  
  17. private ServerSocket serverSo = null; 
    18. 
  
  
  
  18. // current socket 
    19. 
  
  
  
  19. private Socket so = null
    20. 
  
  
  
  20. private OutputStream output = null; 
    21. 
  
  
  
  21. private InputStream input = null; 
    22. 
  
  
  
  22. // gate command 
    23. 
  
  
  
  23. private SGIP_Command tmpCmd = null; 
    24. 
  
  
  
  24. private SGIP_Command cmd = null; 
    25. 
  
  
  
  25. private Bind bind = null; 
    26. 
  
  
  
  26. private BindResp bindResp = null; 
    27. 
  
  
  
  27. //private Unbind unBind = null; 
    28. 
  
  
  
  28. private UnbindResp unBindResp = null; 
    29. 
  
  
  
  29. private boolean unAcceptErrorFlag = true; 
    30. 
  
  
  
  30. Logger unioncomLog = Logger.getLogger(Unioncom
    Deliver.class.getName()); 
    31. 
  
  
  
  31. public UnioncomDeliver() { 
    32. 
  
  
  
  32. } 
    33. 
  
  
  
  33. public void run() { 
    34. 
  
  
  
  34. unioncomLog.info("Start..."); 
    35. 
  
  
  
  35. while (unInterrupt) { 
    36. 
  
  
  
  36. this.initServer(); 
    37. 
  
  
  
  37. this.startServices(); 
    38. 
  
  
  
  38. while (this.unAcceptErrorFlag) { 
    39. 
  
  
  
  39. try { 
    40. 
  
  
  
  40. //接受连接请求 
    41. 
  
  
  
  41. unioncomLog.info("before accept connection!....... 
    FreeMemroy :" + Runtime.getRuntime().freeMemory()); 
    42. 
  
  
  
  42. this.acceptConnection(); 
    43. 
  
  
  
  43. unioncomLog.info("after accept connection!....... 
    FreeMemroy :" + Runtime.getRuntime().freeMemory()); 
    44. 
  
  
  
  44. while (unErr) { 
    45. 
  
  
  
  45. cmd = new Command(); 
    46. 
  
  
  
  46. unioncomLog.info("before read command from stream
    ........... FreeMemroy: " + Runtime.getRuntime().
    freeMemory()); 
    47. 
  
  
  
  47. tmpCmd = cmd.read(input); 
    48. 
  
  
  
  48. unioncomLog.info("after read command from stream " + 
    getCommandString(cmd.getCommandID()) + " FreeMemroy: " + 
    Runtime.getRuntime().freeMemory()); 
    49. 
  
  
  
  49. if (tmpCmd == null) { 
    50. 
  
  
  
  50. unErr = false; 
    51. 
  
  
  
  51. break; 
    52. 
  
  
  
  52. } 
    53. 
  
  
  
  53. switch (cmd.getCommandID()) { 
    54. 
  
  
  
  54. // biad ready communication 
    55. 
  
  
  
  55. case SGIP_Command.ID_SGIP_BIND: { 
    56. 
  
  
  
  56. this.dealBind(); 
    57. 
  
  
  
  57. break; 
    58. 
  
  
  
  58. }// exit bind 
    59. 
  
  
  
  59. case SGIP_Command.ID_SGIP_UNBIND: { 
    60. 
  
  
  
  60. this.dealUnBind(); 
    61. 
  
  
  
  61. unioncomLog.info("after unbind connection!....... 
    FreeMemroy :" + Runtime.getRuntime().freeMemory()); 
    62. 
  
  
  
  62. break; 
    63. 
  
  
  
  63. }// deliver 
    64. 
  
  
  
  64. .... 
    65. 
  
  
  
  65. default : //错误的命令字 
    66. 
  
  
  
  66. break; 
    67. 
  
  
  
  67. }// switch 
    68. 
  
  
  
  68. }// while(unErr) 
    69. 
  
  
  
  69. } catch (Exception e) { 
    70. 
  
  
  
  70. unioncomLog.error("Unioncom Recv Service Error" 
    71. 
  
  
  
  71. + e.getMessage());  
    72. 
  
  
  
  72. } finally { 
    73. 
  
  
  
  73. if (this.so != null) { 
    74. 
  
  
  
  74. this.closeSocket(); 
    75. 
  
  
  
  75. } 
    76. 
  
  
  
  76. this.unErr = true; 
    77. 
  
  
  
  77. } 
    78. 
  
  
  
  78. }// while (this.unAcceptErrorFlag) 
    79. 
  
  
  
  79. try { 
    80. 
  
  
  
  80. this.closeServerSocket(); 
    81. 
  
  
  
  81. sleep(200);// sleep 
    82. 
  
  
  
  82. } catch (InterruptedException ie) { 
    83. 
  
  
  
  83. } 
    84. 
  
  
  
  84. }// while(unInterrupt) 
    85. 
  
  
  
  85. } 
    86. 
  
  
  
  86. private String getCommandString(int cmd){ 
    87. 
  
  
  
  87. switch (cmd) { 
    88. 
  
  
  
  88. // biad ready communication 
    89. 
  
  
  
  89. case SGIP_Command.ID_SGIP_BIND: { 
    90. 
  
  
  
  90. return " BIND COMMAND ";  
    91. 
  
  
  
  91. }// exit bind 
    92. 
  
  
  
  92. case SGIP_Command.ID_SGIP_UNBIND: { 
    93. 
  
  
  
  93. return " UNBIND COMMAND ";  
    94. 
  
  
  
  94. }// deliver 
    95. 
  
  
  
  95. case ... 
    96. 
  
  
  
  96. default: 
    97. 
  
  
  
  97. return " UNKNOWN COMMAND";  
    98. 
  
  
  
  98. } 
    99. 
  
  
  
  99. } 
    100. 
  
  
  
  100. private void dealBind() { 
    101. 
  
  
  
  101. try { 
    102. 
  
  
  
  102. bind = new Bind(tmpCmd); 
    103. 
  
  
  
  103. if (bind.readbody() != 0) { 
    104. 
  
  
  
  104. unioncomLog.warn("Read Bind error"); 
    105. 
  
  
  
  105. this.unErr = false; 
    106. 
  
  
  
  106. } 
    107. 
  
  
  
  107. bindResp = new BindResp(tmpCmd.getMsgHead()); 
    108. 
  
  
  
  108. bindResp.SetResult(0); 
    109. 
  
  
  
  109. bindResp.write(output); 
    110. 
  
  
  
  110. unioncomLog.debug("Bind success!"); 
    111. 
  
  
  
  111. } catch (Exception e) { 
    112. 
  
  
  
  112. unioncomLog.error("Dela Union Recv Bind Error!" + 
    e.getMessage()); 
    113. 
  
  
  
  113. this.unErr = false; 
    114. 
  
  
  
  114. } 
    115. 
  
  
  
  115. } 
    116. 
  
  
  
  116. private void dealUnBind() { 
    117. 
  
  
  
  117. try { 
    118. 
  
  
  
  118. //unBind = (Unbind) tmpCmd; 
    119. 
  
  
  
  119. unBindResp = new UnbindResp(tmpCmd.getMsgHead()); 
    120. 
  
  
  
  120. unBindResp.write(output); 
    121. 
  
  
  
  121. unioncomLog.debug("UnBind success!"); 
    122. 
  
  
  
  122. } catch (Exception e) { 
    123. 
  
  
  
  123. unioncomLog.warn("Unbind error!" + e.getMessage()); 
    124. 
  
  
  
  124. } 
    125. 
  
  
  
  125. this.unErr = false; 
    126. 
  
  
  
  126. } 
    127. 
  
  
  
  127. private void startServices() { 
    128. 
  
  
  
  128. boolean unStartServices = true; 
    129. 
  
  
  
  129. while (unStartServices) { 
    130. 
  
  
  
  130. try { 
    131. 
  
  
  
  131. serverSo = new ServerSocket(ugInfo.getLocalServerPort(), 5, 
    132. 
  
  
  
  132. InetAddress.getByName(ugInfo.getLocalIpAdd())); 
    133. 
  
  
  
  133. //serverSo.setSoTimeout(60000); 
    134. 
  
  
  
  134. unStartServices = false;  
    135. 
  
  
  
  135. unioncomLog.info("Create union recv socket Ok!"); 
    136. 
  
  
  
  136. } catch (IOException e) { 
    137. 
  
  
  
  137. unioncomLog.warn("Create union recv socket error!" 
    138. 
  
  
  
  138. + e.getMessage()); 
    139. 
  
  
  
  139. unStartServices = true; 
    140. 
  
  
  
  140. UnioncomSubmit.thrSlp(3000); 
    141. 
  
  
  
  141. } 
    142. 
  
  
  
  142. } 
    143. 
  
  
  
  143. } 
    144. 
  
  
  
  144. private void acceptConnection() { 
    145. 
  
  
  
  145. // Accept 失败 
    146. 
  
  
  
  146. try {  
    147. 
  
  
  
  147. so = serverSo.accept(); 
    148. 
  
  
  
  148. so.setSoTimeout(10000); 
    149. 
  
  
  
  149. } catch (Exception e) { 
    150. 
  
  
  
  150. unioncomLog.warn("Accept Error!" + e.getMessage()); 
    151. 
  
  
  
  151. this.closeServerSocket(); 
    152. 
  
  
  
  152. this.unAcceptErrorFlag = false; 
    153. 
  
  
  
  153. this.unErr=false; 
    154. 
  
  
  
  154. } 
    155. 
  
  
  
  155. // Accept成功 
    156. 
  
  
  
  156. try { 
    157. 
  
  
  
  157. input = so.getInputStream(); 
    158. 
  
  
  
  158. output = so.getOutputStream(); 
    159. 
  
  
  
  159. } catch (IOException e) { 
    160. 
  
  
  
  160. unioncomLog.warn("Get I/O stream Error!" + e.getMessage()); 
    161. 
  
  
  
  161. this.closeService(); 
    162. 
  
  
  
  162. this.unAcceptErrorFlag = false; 
    163. 
  
  
  
  163. this.unErr=false; 
    164. 
  
  
  
  164. } 
    165. 
  
  
  
  165. } 
    166. 
  
  
  
  166. private void closeSocket() { 
    167. 
  
  
  
  167. try { 
    168. 
  
  
  
  168. so.close(); 
    169. 
  
  
  
  169. unioncomLog.info("Socket Close Success!!!"); 
    170. 
  
  
  
  170. } catch (Exception e) { 
    171. 
  
  
  
  171. unioncomLog.error("Socket Close Failure!!!" + e.getMessage()); 
    172. 
  
  
  
  172. } 
    173. 
  
  
  
  173. } 
    174. 
  
  
  
  174. private void closeServerSocket() { 
    175. 
  
  
  
  175. try { 
    176. 
  
  
  
  176. serverSo.close(); 
    177. 
  
  
  
  177. unioncomLog.info("ServerSocket Close Success!!!"); 
    178. 
  
  
  
  178. } catch (Exception e) { 
    179. 
  
  
  
  179. unioncomLog 
    180. 
  
  
  
  180. .error("ServerSocket Close Failure!!!" + e.getMessage()); 
    181. 
  
  
  
  181. } 
    182. 
  
  
  
  182. } 
    183. 
  
  
  
  183. private void closeService() { 
    184. 
  
  
  
  184. this.closeSocket(); 
    185. 
  
  
  
  185. this.closeServerSocket(); 
    186. 
  
  
  
  186. } 
    187. 
  
  
  
  187. private void initServer() { 
    188. 
  
  
  
  188. this.bind = null; 
    189. 
  
  
  
  189. this.bindResp = null; 
    190. 
  
  
  
  190. //this.unBind = null; 
    191. 
  
  
  
  191. this.unBindResp = null; 
    192. 
  
  
  
  192. this.tmpCmd = null; 
    193. 
  
  
  
  193. this.cmd = null; 
    194. 
  
  
  
  194. this.serverSo = null; 
    195. 
  
  
  
  195. this.so = null; 
    196. 
  
  
  
  196. this.output = null; 
    197. 
  
  
  
  197. this.input = null; 
    198. 
  
  
  
  198. this.unErr = true; 
    199. 
  
  
  
  199. //this.closeSocketFlag = false; 
    200. 
  
  
  
  200. unioncomLog.info("Memory***===" 
    201. 
  
  
  
  201. + java.lang.Runtime.getRuntime().freeMemory()); 
    202. 
  
  
  
  202. } 
    203. 
  
  
  
  203. public synchronized void requireStop() { 
    204. 
  
  
  
  204. this.unInterrupt = false; 
    205. 
  
  
  
  205. unioncomLog.info("Requre interrupt!!!"); 
    206. 
  
  
  
  206. } 
    207. 
  
  
  
  207. public String convertMsgContentCoding
    (int msgCoding, byte[] msgContent) { 
    208. 
  
  
  
  208. String deliverContent = null; 
    209. 
  
  
  
  209. try { 
    210. 
  
  
  
  210. if (msgContent != null) { 
    211. 
  
  
  
  211. if (msgCoding == 8) { // 处理ucs32编码 
    212. 
  
  
  
  212. deliverContent = new String(msgContent, 
    213. 
  
  
  
  213. "UnicodeBigUnmarked"); 
    214. 
  
  
  
  214. } else if (msgCoding == 0) { // 处理ASCII编码 
    215. 
  
  
  
  215. deliverContent = new String(msgContent, "ASCII"); 
    216. 
  
  
  
  216. } else if (msgCoding == 4) { // 处理binary编码 
    217. 
  
  
  
  217. deliverContent = new String(msgContent); 
    218. 
  
  
  
  218. } else if (msgCoding == 15) { // 处理GBK编码 
    219. 
  
  
  
  219. deliverContent = new String(msgContent, "GBK"); 
    220. 
  
  
  
  220. // 处理DELIVER数据包的短信息ID 
    221. 
  
  
  
  221. } else { 
    222. 
  
  
  
  222. unioncomLog.error("编码格式错误!"); 
    223. 
  
  
  
  223. return ""; 
    224. 
  
  
  
  224. } 
    225. 
  
  
  
  225. } else 
    226. 
  
  
  
  226. return ""; 
    227. 
  
  
  
  227. return deliverContent; 
    228. 
  
  
  
  228. } catch (UnsupportedEncodingException ex) { 
    229. 
  
  
  
  229. unioncomLog.error("deal content error!" +
     ex.getMessage()); 
    230. 
  
  
  
  230. return ""; 
    231. 
  
  
  
  231. } 
    232. 
  
  
  
  232. } 
    233. 
  
  
  
  233. }
    234.

以上就是对Java Socket通信的详细介绍。希望大家有所帮助。

名称栏目：JavaSocket通信如何进行通用服务器代码编写
网页地址：http://www.shufengxianlan.com/qtweb/news31/380981.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

网站维护知识

分类信息网站

温江服务器托管　　 　成都申请ssl证书　　 　重庆花箱　　 　LED显示屏厂家　　 　郫县门窗定制　　 　犀浦防护栏定制　　 　成都温江机房　　 　南充护栏钻孔机　　 　遂宁网站建设　　 　搜索引擎优化　　 　成都电信服务器托管　　 　营销型网站建设　　 　成都光华机房　　 　营山网站建设　　 　青年旅行社　　 　绵阳服务器托管　　 　成都力比特　　 　成都网站设计　　 　成都LED显示屏　　 　成都网站设计