`
txf2004
  • 浏览: 6853416 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

Java Socket多线程服务端、客户端

 
阅读更多

Java Socket多线程服务端、客户端

分类： JAVA 2011-11-08 22:49 87人阅读 评论(0) 收藏 举报
view plain
  1. //主方法
  2. packagecom.huhai.demo.socket;
  4. publicclassMain{
  6. /**功能说明：
  7. *@paramargs
  8. *@author胡海
  9. *@throwsInterruptedException
  10. *@since2011-11-8下午05:08:05
  11. */
  13. publicstaticvoidmain(String[]args)throwsInterruptedException{
  14. ThreadserverTthread=newThread(newRunnable(){
  15. publicvoidrun(){
  16. newSocketServer();
  17. }
  18. });
  19. serverTthread.start();
  20. Thread.sleep(1000);
  21. ThreadclientThread=newThread(newRunnable(){
  22. publicvoidrun(){
  23. newSocketClient();
  24. }
  25. });
  26. clientThread.start();
  27. }
  29. }
  33. //客户端
  34. <prename="code"class="java">packagecom.huhai.demo.socket;
  36. importjava.io.BufferedReader;
  37. importjava.io.InputStreamReader;
  38. importjava.io.PrintWriter;
  39. importjava.net.Socket;
  41. publicclassSocketClient{
  42. privateSocketsocket;
  43. privateintport=10000;
  44. privateStringhostIp="127.0.0.1";
  46. publicSocketClient(){
  47. try{
  48. Stringmessage=null;
  49. BufferedReaderin=null;
  50. PrintWriterout=null;
  51. BufferedReaderline=null;
  52. while(!SocketCommand.CONST_QUIT.equals(message)){
  53. socket=newSocket(hostIp,port);
  54. in=newBufferedReader(newInputStreamReader(socket.getInputStream()));
  55. out=newPrintWriter(socket.getOutputStream(),true);
  56. line=newBufferedReader(newInputStreamReader(System.in));
  58. System.out.println("pleaseinputsomecharacters:");
  59. message=line.readLine();
  60. out.println(message);
  61. System.out.println("Backmessagefromserver:["+in.readLine()+"]");
  62. }
  63. System.out.println("Clientexit.");
  64. line.close();
  65. out.close();
  66. in.close();
  67. socket.close();
  68. }catch(Exceptione){
  69. e.printStackTrace();
  70. }
  71. }
  73. publicstaticvoidmain(String[]args){
  74. newSocketClient();
  76. }
  78. }

//服务端
view plain
  1. packagecom.huhai.demo.socket;
  3. importjava.io.BufferedReader;
  4. importjava.io.IOException;
  5. importjava.io.InputStreamReader;
  6. importjava.io.PrintWriter;
  7. importjava.net.ServerSocket;
  8. importjava.net.Socket;
  9. importjava.util.concurrent.ExecutorService;
  10. importjava.util.concurrent.Executors;
  12. publicclassSocketServer{
  13. privateServerSocketserverSocket;
  14. privateSocketsocket;
  15. privateintport=10000;
  16. privateExecutorServiceexecuteService=Executors.newFixedThreadPool(10);
  18. publicSocketServer(){
  19. try{
  20. serverSocket=newServerSocket(port);
  21. //serverSocket=newServerSocket(port,10,InetAddress.getByName("192.168.1.102"));
  22. System.out.println("SocketServerhavebeenstarted.["+serverSocket+"]");
  23. while(true){
  24. socket=serverSocket.accept();
  25. executeService.submit(newRunnable(){
  26. publicvoidrun(){
  27. try{
  28. BufferedReaderin=newBufferedReader(newInputStreamReader(socket.getInputStream()));
  29. PrintWriterout=newPrintWriter(socket.getOutputStream(),true);
  31. Stringline=in.readLine();
  32. System.out.println("ServerReceived:["+line+"]");
  33. out.println("ServerReceived:["+line+"]");
  34. out.close();
  35. in.close();
  36. }catch(Exceptione){
  37. e.printStackTrace();
  38. }finally{
  39. try{
  40. socket.close();
  41. }catch(IOExceptione){
  42. System.out.println("closesocketerror.");
  43. e.printStackTrace();
  44. }
  45. }
  46. }
  47. });
  48. }
  49. }catch(Exceptione){
  50. e.printStackTrace();
  51. }finally{
  52. try{
  53. if(null!=serverSocket){
  54. serverSocket.close();
  55. System.out.println("serverSocketclose");
  56. }
  57. }catch(Exceptione){
  58. e.printStackTrace();
  59. }
  60. }
  61. }
  63. publicstaticvoidmain(String[]args){
  64. newSocketServer();
  65. }
  67. }

//常量
view plain
  1. packagecom.huhai.demo.socket;
  3. publicclassSocketCommand{
  4. publicstaticfinalStringCONST_QUIT="quit";
  5. }

运行结果：


view plain
  1. //主方法
  2. packagecom.huhai.demo.socket;
  4. publicclassMain{
  6. /**功能说明：
  7. *@paramargs
  8. *@author胡海
  9. *@throwsInterruptedException
  10. *@since2011-11-8下午05:08:05
  11. */
  13. publicstaticvoidmain(String[]args)throwsInterruptedException{
  14. ThreadserverTthread=newThread(newRunnable(){
  15. publicvoidrun(){
  16. newSocketServer();
  17. }
  18. });
  19. serverTthread.start();
  20. Thread.sleep(1000);
  21. ThreadclientThread=newThread(newRunnable(){
  22. publicvoidrun(){
  23. newSocketClient();
  24. }
  25. });
  26. clientThread.start();
  27. }
  29. }
  33. //客户端
  34. <prename="code"class="java">packagecom.huhai.demo.socket;
  36. importjava.io.BufferedReader;
  37. importjava.io.InputStreamReader;
  38. importjava.io.PrintWriter;
  39. importjava.net.Socket;
  41. publicclassSocketClient{
  42. privateSocketsocket;
  43. privateintport=10000;
  44. privateStringhostIp="127.0.0.1";
  46. publicSocketClient(){
  47. try{
  48. Stringmessage=null;
  49. BufferedReaderin=null;
  50. PrintWriterout=null;
  51. BufferedReaderline=null;
  52. while(!SocketCommand.CONST_QUIT.equals(message)){
  53. socket=newSocket(hostIp,port);
  54. in=newBufferedReader(newInputStreamReader(socket.getInputStream()));
  55. out=newPrintWriter(socket.getOutputStream(),true);
  56. line=newBufferedReader(newInputStreamReader(System.in));
  58. System.out.println("pleaseinputsomecharacters:");
  59. message=line.readLine();
  60. out.println(message);
  61. System.out.println("Backmessagefromserver:["+in.readLine()+"]");
  62. }
  63. System.out.println("Clientexit.");
  64. line.close();
  65. out.close();
  66. in.close();
  67. socket.close();
  68. }catch(Exceptione){
  69. e.printStackTrace();
  70. }
  71. }
  73. publicstaticvoidmain(String[]args){
  74. newSocketClient();
  76. }
  78. }

//服务端
view plain
  1. packagecom.huhai.demo.socket;
  3. importjava.io.BufferedReader;
  4. importjava.io.IOException;
  5. importjava.io.InputStreamReader;
  6. importjava.io.PrintWriter;
  7. importjava.net.ServerSocket;
  8. importjava.net.Socket;
  9. importjava.util.concurrent.ExecutorService;
  10. importjava.util.concurrent.Executors;
  12. publicclassSocketServer{
  13. privateServerSocketserverSocket;
  14. privateSocketsocket;
  15. privateintport=10000;
  16. privateExecutorServiceexecuteService=Executors.newFixedThreadPool(10);
  18. publicSocketServer(){
  19. try{
  20. serverSocket=newServerSocket(port);
  21. //serverSocket=newServerSocket(port,10,InetAddress.getByName("192.168.1.102"));
  22. System.out.println("SocketServerhavebeenstarted.["+serverSocket+"]");
  23. while(true){
  24. socket=serverSocket.accept();
  25. executeService.submit(newRunnable(){
  26. publicvoidrun(){
  27. try{
  28. BufferedReaderin=newBufferedReader(newInputStreamReader(socket.getInputStream()));
  29. PrintWriterout=newPrintWriter(socket.getOutputStream(),true);
  31. Stringline=in.readLine();
  32. System.out.println("ServerReceived:["+line+"]");
  33. out.println("ServerReceived:["+line+"]");
  34. out.close();
  35. in.close();
  36. }catch(Exceptione){
  37. e.printStackTrace();
  38. }finally{
  39. try{
  40. socket.close();
  41. }catch(IOExceptione){
  42. System.out.println("closesocketerror.");
  43. e.printStackTrace();
  44. }
  45. }
  46. }
  47. });
  48. }
  49. }catch(Exceptione){
  50. e.printStackTrace();
  51. }finally{
  52. try{
  53. if(null!=serverSocket){
  54. serverSocket.close();
  55. System.out.println("serverSocketclose");
  56. }
  57. }catch(Exceptione){
  58. e.printStackTrace();
  59. }
  60. }
  61. }
  63. publicstaticvoidmain(String[]args){
  64. newSocketServer();
  65. }
  67. }

//常量
view plain
  1. packagecom.huhai.demo.socket;
  3. publicclassSocketCommand{
  4. publicstaticfinalStringCONST_QUIT="quit";
  5. }

运行结果：

分享到：
| Java多线程示例：4个售票员卖1000张火车票
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics