首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 计算机考试 > 认证考试 > JAVA认证 >

Java认证网络socket编程详解5--开发客户端代码(1)

2012-12-26 来源:读书人 
开发客户端代码

  开发客户端代码

  我们可以按以下的步骤开发基于多线程的服务器端的代码。

  第一步,在3.2里创建的“TCPSocket”项目里,新建一个名为ThreadServer.java的代码文件,创建文件的方式大家可以参照3.2部分的描述。首先编写package和import部分的代码,用来打包和引入包文件,如下所示:

  package tcp;

  import java.io.*;

  import java.net.*;

  第二步,由于我们在服务器端引入线程机制,所以我们要编写线程代码的主体执行类ServerThreadCode,这个类的代码如下所示:

  class ServerThreadCode extends Thread

  {

  //客户端的socket

  private Socket clientSocket;

  //IO句柄

  private BufferedReader sin;

  private PrintWriter sout;

  //默认的构造函数

  public ServerThreadCode()

  {}

  public ServerThreadCode(Socket s) throws IOException

  {

  clientSocket = s;

  //初始化sin和sout的句柄

  sin = new BufferedReader(new InputStreamReader(clientSocket

  .getInputStream()));

  sout = new PrintWriter(new BufferedWriter(new OutputStreamWriter(

  clientSocket.getOutputStream())), true);

  //开启线程

  start();

  //线程执行的主体函数

  public void run()

  {

  try

  {

  //用循环来监听通讯内容

  for(;;)

  {

  String str = sin.readLine();

  //如果接收到的是byebye,退出本次通讯

  if (str.equals("byebye"))

  {

  break;

  }

  System.out.println("In Server reveived the info: " + str);

  sout.println(str);

  }

  System.out.println("closing the server socket!");

  }

  catch (IOException e)

  {

  e.printStackTrace();

  }

  finally

  {

  System.out.println("close the Server socket and the io.");

  try

  {

  clientSocket.close();

  }

  catch (IOException e)

  {

  e.printStackTrace();

  }

  }

  }

  这个类的业务逻辑说明如下:

  1. 这个类通过继承Thread类来实现线程的功能,也就是说,在其中的run方法里,定义了该线程启动后要执行的业务动作。

  2. 这个类提供了两种类型的重载函数。在参数类型为Socket的构造函数里, 通过参数,初始化了本类里的Socket对象,同时实例化了两类IO对象。在此基础上,通过start方法,启动定义在run方法内的本线程的业务逻辑。

  3. 在定义线程主体动作的run方法里,通过一个for(;;)类型的循环,根据IO句柄,读取从Socket信道上传输过来的客户端发送的通讯信息。如果得到的信息为“byebye”,则表明本次通讯结束,退出for循环。

  4. catch从句将处理在try语句里遇到的IO错误等异常,而在finally从句里,将在通讯结束后关闭客户端的Socket句柄。

  上述的线程主体代码将会在ThreadServer类里被调用。

  第三步,编写服务器端的主体类ThreadServer,代码如下所示:

  public class ThreadServer

  {

  //端口号

  static final int portNo = 3333;

  public static void main(String[] args) throws IOException

  {

  //服务器端的socket

  ServerSocket s = new ServerSocket(portNo);

  System.out.println("The Server is start: " + s);

  try

  {

  for(;;)

  {

  //阻塞,直到有客户端连接

  Socket socket = s.accept();

  //通过构造函数,启动线程

  new ServerThreadCode(socket);

  }

  }

  finally

  {

  s.close();

  }

  }


(作者:读书人网友 编辑:kind887)
热点排行