Java如何创建多线程服务器？

在Java编程中，如何创建多线程服务器？

以下示例演示如何使用ServerSocket类的MultiThreadServer(socketname)方法和Socket类的ssock.accept()方法来创建多线程服务器。

package com.yiibai;

import java.io.IOException;

import java.io.PrintStream;

import java.net.ServerSocket;

import java.net.Socket;

public class MultiThreadServer implements Runnable {

   Socket csocket;

   MultiThreadServer(Socket csocket) {

      this.csocket = csocket;

   }

   public static void main(String args[]) throws Exception {

      ServerSocket ssock = new ServerSocket(8806);

      System.out.println("Server Start and Listening: ");

      while (true) {

         Socket sock = ssock.accept();

         System.out.println("Connected");

         new Thread(new MultiThreadServer(sock)).start();

      }

   }

   public void run() {

      try {

         PrintStream pstream = new PrintStream(csocket.getOutputStream());

         for (int i = 100; i >= 0; i--) {

            pstream.println(i + " bottles of beer on the wall");

         }

         pstream.close();

         csocket.close();

      } catch (IOException e) {

         System.out.println(e);

      }

   }

}

Java

上述代码示例将产生以下结果 -

Server Start and Listening:

Shell

示例-2

以下是如何创建多线程服务器的另一个示例。

package com.yiibai;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

import java.text.SimpleDateFormat;

import java.util.Calendar;

public class MultiThreadServer2 {

    ServerSocket myServerSocket;

    boolean ServerOn = true;

    public MultiThreadServer2() {

      try {

         myServerSocket = new ServerSocket(12345);

      } catch(IOException ioe) {

         System.out.println("Could not create server socket on port 12345. Quitting.");

         System.exit(-1);

      } 

      Calendar now = Calendar.getInstance();

      SimpleDateFormat formatter = new SimpleDateFormat(

         "yyyy/MM/dd \'at\' hh:mm:ss ");

      System.out.println("It is now : " + formatter.format(now.getTime()));

      while(ServerOn) {

         try {

            Socket clientSocket = myServerSocket.accept();

            ClientServiceThread cliThread = new ClientServiceThread(clientSocket);

            cliThread.start();

         } catch(IOException ioe) {

            System.out.println("Exception found on accept. Ignoring. Stack Trace :");

            ioe.printStackTrace();

         }

      }

      try {

         myServerSocket.close();

         System.out.println("Server Stopped");

      } catch(Exception ioe) {

         System.out.println("Error Found stopping server socket");

         System.exit(-1);

      }

   }

    public static void main(String[] args) {

        new MultiThreadServer2();

    }

    class ClientServiceThread extends Thread {

        Socket myClientSocket;

        boolean m_bRunThread = true;

        public ClientServiceThread() {

            super();

        }

        ClientServiceThread(Socket s) {

            myClientSocket = s;

        }

        public void run() {

            BufferedReader in = null;

            PrintWriter out = null;

            System.out.println("Accepted Client Address - " + myClientSocket.getInetAddress().getHostName());

            try {

                in = new BufferedReader(new InputStreamReader(myClientSocket.getInputStream()));

                out = new PrintWriter(new OutputStreamWriter(myClientSocket.getOutputStream()));

                while (m_bRunThread) {

                    String clientCommand = in.readLine();

                    System.out.println("Client Says :" + clientCommand);

                    if (!ServerOn) {

                        System.out.print("Server has already stopped");

                        out.println("Server has already stopped");

                        out.flush();

                        m_bRunThread = false;

                    }

                    if (clientCommand.equalsIgnoreCase("quit")) {

                        m_bRunThread = false;

                        System.out.print("Stopping client thread for client : ");

                    } else if (clientCommand.equalsIgnoreCase("end")) {

                        m_bRunThread = false;

                        System.out.print("Stopping client thread for client : ");

                        ServerOn = false;

                    } else {

                        out.println("Server Says : " + clientCommand);

                        out.flush();

                    }

                }

            } catch (Exception e) {

                e.printStackTrace();

            } finally {

                try {

                    in.close();

                    out.close();

                    myClientSocket.close();

                    System.out.println("...Stopped");

                } catch (IOException ioe) {

                    ioe.printStackTrace();

                }

            }

        }

    }

}

Java

上述代码示例将产生以下结果 -

It is now : 2017/09/20 at 10:45:19

Shell

package com.yiibai;

import java.io.IOException;

import java.net.InetAddress;

import java.net.Socket;

import java.net.SocketException;

import java.net.UnknownHostException;

public class SocketClient {

    public static void main(String[] args) {

        try {

            //InetAddress addr = InetAddress.getByName("127.0.0.1");

            Socket theSocket = new Socket("127.0.0.1", 12345);

            System.out.println("Connected to " + theSocket.getInetAddress() + " on port " + theSocket.getPort()

                    + " from port " + theSocket.getLocalPort() + " of " + theSocket.getLocalAddress());

        } catch (UnknownHostException e) {

            System.err.println("I can't find " + e);

        } catch (SocketException e) {

            System.err.println("Could not connect to " + e);

        } catch (IOException e) {

            System.err.println(e);

        }

    }

}

巴特西

Java如何创建多线程服务器？

最新文章

热门文章