JAVA BIO 服务器与客户端实现示例

简介:

代码只兼容JAVA 7及以上版本。


服务器端代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
package  com.stevex.app.bio;
 
import  java.io.BufferedReader;
import  java.io.IOException;
import  java.io.InputStreamReader;
import  java.io.PrintWriter;
import  java.net.ServerSocket;
import  java.net.Socket;
 
import  javax.net.ServerSocketFactory;
 
public  class  XiaoNa {
     public  static  void  main(String[] args){
         XiaoNa xiaona =  new  XiaoNa();
         
         ServerSocket serverSocket =  null ;
         Socket socket =  null ;
 
         try  {
             //可以设置客户连接请求队列的长度,比如5,队列长度超过5后拒绝连接请求
             //serverSocket = ServerSocketFactory.getDefault().createServerSocket(8383, 5);      
             serverSocket = ServerSocketFactory.getDefault().createServerSocket( 8383 );
             
             while ( true ){
                 try {
                     //监听直到接受连接后返回一个新Socket对象
                     socket = serverSocket.accept(); //阻塞
                     //new一个线程处理连接请求
                     new  Thread(xiaona. new  Worker(socket)).start();;
                 }
                 catch  (Throwable e) {     //防止发生异常搞死服务器          
                     e.printStackTrace();
                 }              
             }          
         catch  (IOException e) {              
             e.printStackTrace();
         }
         finally {               
             try  {             
                 if (socket !=  null ){
                     socket.close();
                 }
             catch  (IOException e) {
                 e.printStackTrace();
             }  
         }
     }
     
     private  static  String getAnswer(String question){
         String answer =  null ;
         
         switch (question){
         case  "who" :
             answer =  "我是小娜" ;
             break ;
         case  "what" :
             answer =  "我是来帮你解闷的" ;
             break ;
         case  "where" :
             answer =  "我来自外太空" ;
             break ;
         default :
                 answer =  "请输入 who, 或者what, 或者where" ;
         }
         
         return  answer;
     }
     
     private  class  Worker  implements  Runnable{
         private  Socket socket;
         
         public  Worker(Socket socket){
             this .socket = socket;
         }
         
         @Override
         public  void  run() {
             BufferedReader reader =  null ;
             PrintWriter writer =  null ;
             
             try  {
                 reader =  new  BufferedReader( new  InputStreamReader(socket.getInputStream()));
             
                 writer =  new  PrintWriter(socket.getOutputStream());
                 
                 String question = reader.readLine(); //没有内容会阻塞
                 
                 while (!question.equals( "OVER" )){
                     String answer = getAnswer(question);
                     writer.println(answer);
                     question = reader.readLine();
                 }
                 
                 writer.println( "OVER" ); //OVER作为操作完成暗号
                 writer.flush();
                 
                 if (writer !=  null ){
                     writer.close();
                 }
                                     
                 if (reader !=  null ){
                     reader.close();
                 }
             catch  (IOException e) {
                 e.printStackTrace();
             }
         }
         
     }
}


客户端代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
package  com.stevex.app.bio;
 
import  java.io.BufferedReader;
import  java.io.IOException;
import  java.io.InputStreamReader;
import  java.io.PrintWriter;
import  java.net.Socket;
 
public  class  Client {
     public  static  void  main(String[] args) {
         Client c =  new  Client();
         
         //种20个线程发起Socket客户端连接请求
         for ( int  i= 0 ; i< 20 ; i++){
             new  Thread(c. new  Worker()).start();
         }      
     }
     
     private  class  Worker  implements  Runnable{
 
         @Override
         public  void  run() {
             Socket socket =  null ;
             BufferedReader reader =  null ;
             PrintWriter writer =  null ;
 
             try  {
                 //创建一个Socket并连接到指定的目标服务器
                 socket =  new  Socket( "localhost" 8383 );
 
                 reader =  new  BufferedReader( new  InputStreamReader(
                         socket.getInputStream()));
                 writer =  new  PrintWriter(socket.getOutputStream());
 
                 writer.println( "who" );
                 writer.println( "what" );
                 writer.println( "where" );
                 writer.println( "OVER" ); //OVER作为操作完成暗号
                 writer.flush();
 
                 String answer = reader.readLine();    //没有内容会阻塞      
                 while (! answer.equals( "OVER" )){               
                     System.out.println(Thread.currentThread().getId() +  "---Message from server:"  + answer);
                     answer = reader.readLine();
                 }
 
             catch  (IOException e) {
                 e.printStackTrace();
             finally  {
                 try  {
                     if  (writer !=  null ) {
                         writer.close();
                     }
 
                     if  (reader !=  null ) {
                         reader.close();
                     }
 
                     if  (socket !=  null ) {
                         socket.close();
                     }
                 catch  (IOException e) {
                     e.printStackTrace();
                 }
             }
         }
         
     }
}





     本文转自sarchitect 51CTO博客,原文链接:http://blog.51cto.com/stevex/1581093 ,如需转载请自行联系原作者


相关文章
|
9天前
|
安全 Java 调度
Java编程时多线程操作单核服务器可以不加锁吗?
Java编程时多线程操作单核服务器可以不加锁吗?
26 2
|
7天前
|
Java Linux
java读取linux服务器下某文档的内容
java读取linux服务器下某文档的内容
19 3
java读取linux服务器下某文档的内容
|
9天前
|
Java
java小工具util系列5:java文件相关操作工具,包括读取服务器路径下文件,删除文件及子文件,删除文件夹等方法
java小工具util系列5:java文件相关操作工具,包括读取服务器路径下文件,删除文件及子文件,删除文件夹等方法
22 4
|
12天前
|
JavaScript 前端开发 Java
Java 8 新特性详解及应用示例
Java 8 新特性详解及应用示例
|
18天前
|
Kubernetes Java Maven
揭秘无服务器革命:Quarkus如何让Java应用在云端“零”负担起飞?
本文介绍如何使用Quarkus从零开始开发无服务器应用,通过示例代码和详细步骤引导读者掌握这一技术。无服务器架构让开发者无需管理服务器,具有自动扩展和成本效益等优势。Quarkus作为Kubernetes Native Java框架,优化了Java应用的启动速度和内存使用,适合无服务器环境。文章涵盖环境搭建、项目创建及部署全流程,并介绍了Quarkus的扩展性和监控工具,助力高效开发与应用性能提升。
25 9
|
11天前
|
JSON NoSQL Java
redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
这篇文章介绍了在Java中使用Redis客户端的几种方法,包括Jedis、SpringDataRedis和SpringBoot整合Redis的操作。文章详细解释了Jedis的基本使用步骤,Jedis连接池的创建和使用,以及在SpringBoot项目中如何配置和使用RedisTemplate和StringRedisTemplate。此外,还探讨了RedisTemplate序列化的两种实践方案,包括默认的JDK序列化和自定义的JSON序列化,以及StringRedisTemplate的使用,它要求键和值都必须是String类型。
redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
|
28天前
|
Cloud Native Java 编译器
将基于x86架构平台的应用迁移到阿里云倚天实例云服务器参考
随着云计算技术的不断发展,云服务商们不断推出高性能、高可用的云服务器实例,以满足企业日益增长的计算需求。阿里云推出的倚天实例,凭借其基于ARM架构的倚天710处理器,提供了卓越的计算能力和能效比,特别适用于云原生、高性能计算等场景。然而,有的用户需要将传统基于x86平台的应用迁移到倚天实例上,本文将介绍如何将基于x86架构平台的应用迁移到阿里云倚天实例的服务器上,帮助开发者和企业用户顺利完成迁移工作,享受更高效、更经济的云服务。
将基于x86架构平台的应用迁移到阿里云倚天实例云服务器参考
|
26天前
|
编解码 前端开发 安全
通过阿里云的活动购买云服务器时如何选择实例、带宽、云盘
在我们选购阿里云服务器的过程中,不管是新用户还是老用户通常都是通过阿里云的活动去买了,一是价格更加实惠,二是活动中的云服务器配置比较丰富,足可以满足大部分用户的需求,但是面对琳琅满目的云服务器实例、带宽和云盘选项,如何选择更适合自己,成为许多用户比较关注的问题。本文将介绍如何在阿里云的活动中选择合适的云服务器实例、带宽和云盘,以供参考和选择。
通过阿里云的活动购买云服务器时如何选择实例、带宽、云盘
|
24天前
|
弹性计算 运维 安全
阿里云轻量应用服务器和经济型e实例区别及选择参考
目前在阿里云的活动中,轻量应用服务器2核2G3M带宽价格为82元1年,2核2G3M带宽的经济型e实例云服务器价格99元1年,对于云服务器配置和性能要求不是很高的阿里云用户来说,这两款服务器配置和价格都差不多,阿里云轻量应用服务器和ECS云服务器让用户二选一,很多用户不清楚如何选择,本文来说说轻量应用服务器和经济型e实例的区别及选择参考。
阿里云轻量应用服务器和经济型e实例区别及选择参考
|
25天前
|
机器学习/深度学习 存储 人工智能
阿里云GPU云服务器实例规格gn6v、gn7i、gn6i实例性能及区别和选择参考
阿里云的GPU云服务器产品线在深度学习、科学计算、图形渲染等多个领域展现出强大的计算能力和广泛的应用价值。本文将详细介绍阿里云GPU云服务器中的gn6v、gn7i、gn6i三个实例规格族的性能特点、区别及选择参考,帮助用户根据自身需求选择合适的GPU云服务器实例。
阿里云GPU云服务器实例规格gn6v、gn7i、gn6i实例性能及区别和选择参考
下一篇
无影云桌面