现在的位置: 首页 > 综合 > 正文

步步测试完善Java中Socket通信图解法(二)

2012年11月09日 ⁄ 综合 ⁄ 共 2836字 ⁄ 字号 评论关闭

目录


简介

Java中Socket通信简介

单线程一对一服务器1——>1客户端

单线程一对一服务器1<——>1客户端

多线程一对多服务器1<——>N客户端【非聊天室的服务器通过用户输入发送数据】

多线程一对多服务器1<——>N客户端【聊天室】

多线程最终服务器和客户端集成一体【swing程序】


   
   Java中Tcp协议Socket通信测试步骤:
     

  【单线程】一对一服务器1——>1客户端
 
 
 

     介绍:当客户端连接后,服务器会发送消息到客户端。客户端收到服务器发送来的消息,并输出。
 
     代码如下:客户端和服务器端都在本机上测试。
 
     服务器
    
package com17;
import java.io.IOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
     public static void main(String[] args) {
          //创建月hi个ServerSocket,用于监听客户端Socket的连接请求
          try {
               ServerSocket ss=new ServerSocket(30000);
               //采用死循环不断接受来自客户端的请求
               while(true)
               {
                    //每当接受到客户端socket的请求,服务端也对应产生一个socket
                    Socket s=ss.accept();
                    System.out.println("IP为"+s.getInetAddress()+"连接此服务器");
                    //将Socket对应的输出流包装成PrintStream
                    PrintStream ps=new PrintStream(s.getOutputStream());
                    //进行普通的io操作
                    ps.println("客户端您好,我是服务器。");
                    ps.close();
                    s.close();         
               }
          } catch (IOException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
          }
         
     }

}

   客户端:

 
package com17;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

public class Client {
     public static void main(String[] args) {
          try
          {
               Socket socket=new Socket("127.0.0.1",30000);
               //将socket对应的输入流包装成BufferedReader
               BufferedReader br=new BufferedReader( new InputStreamReader(socket.getInputStream()));
              
               //进行普通的io操作
               String line=br.readLine();
               System.out.println("来自服务器的数据::"+line);
               br.close();
               socket.close();

          }
          catch(IOException e)
          {
               e.printStackTrace();
          }
         
     }

}

  效果如下:

 
 
 
 

【单线程】一对一服务器1<——>1客户端 
 
 

      介绍:服务器和客户端分别接受对方发送的信息,然后再发送数据到对方。
      若是发送已经编译好的数据,则这块是很简单的。
      在第一个demo的基础上,修改服务器端的main方法:
      服务器端:
     
                  while( true)
                {
                      //每当接受到客户端socket的请求,服务端也对应产生一个socket
                     Socket s=ss.accept();
                     System. out.println( "IP为"+s.getInetAddress()+ "连接此服务器" );
                      //接受客户端发送的数据
                     BufferedReader br= new BufferedReader( new InputStreamReader(s.getInputStream()));
                     System. out.println( "来自客户端的数据:" +br.readLine());
                      //将Socket对应的输出流包装成PrintStream
                     PrintStream ps= new PrintStream(s.getOutputStream());
                      //进行普通的 io操作
                     ps.println( "客户端您好,我是服务器。" );
                     ps.close();
                     br.close();
                     s.close();      
                }

  客户端:

 
            try
           {
                Socket socket=new Socket("127.0.0.1",30000);
                 //发送数据
                PrintStream ps= new PrintStream(socket.getOutputStream());
                ps.println( "您好,我是客户端" );
                 //将socket对应的输入流包装成BufferedReader
                BufferedReader br= new BufferedReader( new InputStreamReader(socket.getInputStream()));
                 //进行普通的io操作
                String line=br.readLine();
                System. out.println( "来自服务器的数据::" +line);
                br.close();
                ps.close();
                 socket.close();

           }
效果如下:
 
      注意:服务器和客户端互相发送的数据都是已经编译好的。但是通常情况下,我们发送数据,都是想发什么就发什么,所以呢,应该通过键盘输入来发送数据。
      但是通过键盘输入,需要监听用户键盘输入。这个键盘输入会有一定的问题。
      比如客户端发送数据如下:还是在上述demo的Client端基础上:
     
                //获取该socket对应的输出流
              PrintStream ps= new PrintStream(s.getOutputStream());
              String line= null;
              //不断读取键盘的输入
              BufferedReader br= new BufferedReader( new InputStreamReader(System.in));
              while((line=br.readLine())!= null)
              {
                   //将用户的键盘输入内容写入socket对应的输出流
                   ps.println(line);
              }

     

      请注意看system.in这个方法,则程序一直在死循环中,则无法执行下面的接受服务器方法。
      也许你说,那直接在循环中,发送完毕后,直接接受。
      但是这种办法,就会造成,你在dos窗口中只能发一条语句,然后,等待接受。
      那该怎么办呢?我想发送数据和我的接受数据不相关分离,并不是硬生生滴绑定在一块。

   

抱歉!评论已关闭.