码迷，mamicode.com
首页 > 编程语言 > 详细

Java Socket编程 标准范例（多线程）

时间：2016-03-07 12:02:37      阅读：209      评论：0      收藏：0      [点我收藏+]

标签：

链接地址：http://blog.csdn.net/benweizhu/article/details/6615542

服务器端（Server）非多线程

 

[java] view plain copy
 
  1. package com.zeph.serverclient;  
  2.   
  3. import java.io.BufferedReader;  
  4. import java.io.IOException;  
  5. import java.io.InputStreamReader;  
  6. import java.io.PrintWriter;  
  7. import java.net.ServerSocket;  
  8. import java.net.Socket;  
  9.   
  10. public class MyServer {  
  11.     public static void main(String[] args) throws IOException {  
  12.         ServerSocket server = new ServerSocket(5678);  
  13.         Socket client = server.accept();  
  14.         BufferedReader in = new BufferedReader(new InputStreamReader(  
  15.                 client.getInputStream()));  
  16.         PrintWriter out = new PrintWriter(client.getOutputStream());  
  17.         while (true) {  
  18.             String str = in.readLine();  
  19.             System.out.println(str);  
  20.             out.println("has receive....");  
  21.             out.flush();  
  22.             if (str.equals("end"))  
  23.                 break;  
  24.         }  
  25.         client.close();  
  26.     }  
  27. }  


客户端（Client）

 

 

[java] view plain copy
 
  1. package com.zeph.serverclient;  
  2.   
  3. import java.io.BufferedReader;  
  4. import java.io.InputStreamReader;  
  5. import java.io.PrintWriter;  
  6. import java.net.InetAddress;  
  7. import java.net.Socket;  
  8.   
  9. public class MyClient {  
  10.     static Socket server;  
  11.   
  12.     public static void main(String[] args) throws Exception {  
  13.         server = new Socket(InetAddress.getLocalHost(), 5678);  
  14.         BufferedReader in = new BufferedReader(new InputStreamReader(  
  15.                 server.getInputStream()));  
  16.         PrintWriter out = new PrintWriter(server.getOutputStream());  
  17.         BufferedReader wt = new BufferedReader(new InputStreamReader(System.in));  
  18.         while (true) {  
  19.             String str = wt.readLine();  
  20.             out.println(str);  
  21.             out.flush();  
  22.             if (str.equals("end")) {  
  23.                 break;  
  24.             }  
  25.             System.out.println(in.readLine());  
  26.         }  
  27.         server.close();  
  28.     }  
  29. }  

 

服务器端（Server）多线程

 

[java] view plain copy
 
  1. package com.zeph.multiclient;  
  2.   
  3. import java.io.BufferedReader;  
  4. import java.io.IOException;  
  5. import java.io.InputStreamReader;  
  6. import java.io.PrintWriter;  
  7. import java.net.ServerSocket;  
  8. import java.net.Socket;  
  9.   
  10. public class MultiClient extends Thread {  
  11.     private Socket client;  
  12.   
  13.     public MultiClient(Socket c) {  
  14.         this.client = c;  
  15.     }  
  16.   
  17.     public void run() {  
  18.         try {  
  19.             BufferedReader in = new BufferedReader(new InputStreamReader(  
  20.                     client.getInputStream()));  
  21.             PrintWriter out = new PrintWriter(client.getOutputStream());  
  22.             // Mutil User but can‘t parallel  
  23.   
  24.             while (true) {  
  25.                 String str = in.readLine();  
  26.                 System.out.println(str);  
  27.                 out.println("has receive....");  
  28.                 out.flush();  
  29.                 if (str.equals("end"))  
  30.                     break;  
  31.             }  
  32.             client.close();  
  33.         } catch (IOException ex) {  
  34.         } finally {  
  35.         }  
  36.     }  
  37.   
  38.     public static void main(String[] args) throws IOException {  
  39.         ServerSocket server = new ServerSocket(5678);  
  40.         while (true) {  
  41.             // transfer location change Single User or Multi User  
  42.   
  43.             MultiClient mc = new MultiClient(server.accept());  
  44.             mc.start();  
  45.         }  
  46.     }  
  47. }  


测试这个代码的时候可以直接用DOS控制台上面运行，这样看的效果更清楚！

服务器基本步骤：

1.指定端口实例化一个SeverSocket

2.调用ServerSocket的accept()方法，以在等待连接期间造成阻塞

3.获取位于该底层的Socket的流以进行读写操作

4.将数据封装成流

5.对Socket进行读写

6.关闭打开的流

 

客户端基本步骤：

1.通过IP地址和端口实例化Socket，请求连接服务器

2.获得Socket上的流以进行读写

3.把流封装进BufferedReader/PrintWriter的实例

4.对Socket进行读写

5.关闭打开的流

Java Socket编程 标准范例（多线程）

标签：

原文地址：http://www.cnblogs.com/wvqusrtg/p/5249905.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！