Java 实例 - ServerSocket 和 Socket 通信实例

以下实例演示了如何实现客户端发送消息到服务器，服务器接收到消息并读取输出，然后写出到客户端客户端接收到输出。

1、建立服务器端

服务器建立通信ServerSocket
服务器建立Socket接收客户端连接
建立IO输入流读取客户端发送的数据
建立IO输出流向客户端发送数据消息

服务器端代码:

Server.java 文件

import   java . io . BufferedReader ;
import   java . io . BufferedWriter ;
import   java . io . IOException ;
import   java . io . InputStreamReader ;
import   java . io . OutputStreamWriter ;
import   java . net . ServerSocket ;
import   java . net . Socket ;

public   class   Server   {
    public   static   void   main ( String [ ]   args )   {
       try   {
          ServerSocket   ss  =  new   ServerSocket ( 8888 ) ;
          System . out . println ( " 启动服务器.... " ) ;
          Socket   s  =  ss . accept ( ) ;
          System . out . println ( " 客户端: " + s . getInetAddress ( ) . getLocalHost ( ) + " 已连接到服务器 " ) ;

          BufferedReader   br  =  new   BufferedReader ( new   InputStreamReader ( s . getInputStream ( ) ) ) ;
          // 读取客户端发送来的消息
          String   mess  =  br . readLine ( ) ;
          System . out . println ( " 客户端： " + mess ) ;
          BufferedWriter   bw  =  new   BufferedWriter ( new   OutputStreamWriter ( s . getOutputStream ( ) ) ) ;
          bw . write ( mess + "
" ) ;
          bw . flush ( ) ;
       }   catch   ( IOException   e )   {
          e . printStackTrace ( ) ;
       }
    }
}

以上代码运行输出结果为：

启动服务器....

2、建立客户端

创建Socket通信，设置通信服务器的IP和Port
建立IO输出流向服务器发送数据消息
建立IO输入流读取服务器发送来的数据消息

客户端代码:

Client.java 文件

import   java . io . BufferedReader ;
import   java . io . BufferedWriter ;
import   java . io . IOException ;
import   java . io . InputStream ;
import   java . io . InputStreamReader ;
import   java . io . OutputStream ;
import   java . io . OutputStreamWriter ;
import   java . net . Socket ;
import   java . net . UnknownHostException ;

public   class   Client   {
    public   static   void   main ( String [ ]   args )   {
       try   {
          Socket   s  =  new   Socket ( " 127.0.0.1 " , 8888 ) ;

          // 构建IO
          InputStream   is  =  s . getInputStream ( ) ;
          OutputStream   os  =  s . getOutputStream ( ) ;

          BufferedWriter   bw  =  new   BufferedWriter ( new   OutputStreamWriter ( os ) ) ;
          // 向服务器端发送一条消息
          bw . write ( " 测试客户端和服务器通信，服务器接收到消息返回到客户端
" ) ;
          bw . flush ( ) ;

          // 读取服务器返回的消息
          BufferedReader   br  =  new   BufferedReader ( new   InputStreamReader ( is ) ) ;
          String   mess  =  br . readLine ( ) ;
          System . out . println ( " 服务器： " + mess ) ;
       }   catch   ( UnknownHostException   e )   {
          e . printStackTrace ( ) ;
       }   catch   ( IOException   e )   {
          e . printStackTrace ( ) ;
       }
    }
}

以上代码运行输出结果为：

服务器：测试客户端和服务器通信，服务器接收到消息返回到客户端

程序猿的技术大观园：www.javathinker.net

[这个贴子最后由 flybird 在 2020-01-27 15:37:34 重新编辑]

Java精品书籍推荐