Shulou(Shulou.com)06/01 Report--

This article mainly explains "Java how to use thread pool to achieve socket programming", the content of the article is simple and clear, easy to learn and understand, the following please follow the editor's ideas slowly in depth, together to study and learn "Java how to use thread pool to achieve socket programming" bar!

Preface

Take the socket communication between multiple clients and a server as an example, when the server starts, it creates a fixed size thread pool. After receiving a connection request (communication task), the server sends it to the thread pool for execution. The task class implements the Runnable interface, which is used for reading and writing operations with the client. As tasks, the objects of this class are submitted to the thread pool through execute (Runnable task).

1. A simple Cmax S model is implemented. Server: import java.io.InputStream;import java.net.ServerSocket;import java.net.Socket;public class Server {public static void main (String [] args) throws Exception {System.out.println ("server start"); ServerSocket server = new ServerSocket (1003); while (true) {Socket client = server.accept (); InputStream input = client.getInputStream (); byte [] b = new byte [8196] Int len = input.read (b); System.out.println (new String (b, 0, len)); if (new String (b) .equals ("close") break; client.close ();} server.close ();}} 2. Client: import java.io.OutputStream;import java.net.Socket;import java.util.Scanner;public class Client {public static void main (String [] args) throws Exception {System.out.println ("client start"); Scanner scanner = new Scanner (System.in); Socket client = new Socket ("localhost", 1003); OutputStream out = client.getOutputStream (); while (true) {String str = scanner.nextLine () Out.write (str.getBytes ());}

Only the server can receive client information here.

Second, thread pool usage method 1. Create a new thread pool ExecutorService pool = Executors.newFixedThreadPool (3)

Create a thread pool that reuses a fixed number of threads running on a shared unbounded queue. At any time, up to 3 threads will be active processing tasks. If other tasks are submitted while all threads are active, they will wait in the queue until threads are available. If any thread terminates due to failure during execution before shutting down, if a subsequent task needs to be performed, the new thread will replace it. Threads in the pool will exist until they are explicitly closed.

two。 Use Runnable interface to implement thread private static class InnerThread implements Runnable {public void run ();} 3. Create a thread object and submit it to the thread pool to execute InnerThread innerThread = new InnerThread (); pool.execute (innerThread); third, combine

When a new connection is established, a new thread is created and submitted to the thread pool

While (true) {Socket clientSocket = server.accept (); InnerThread innerThread = new InnerThread (clientSocket); pool.execute (innerThread);}

The run method is about how to handle new connections and the exchange of information between the client and the server.

Fourth, use the new input and output stream

Because the OutputStream and InputStream classes have methods that are not implemented or are not well implemented, we choose to use the

BufferedReader,PrintWriter class to implement communication.

Server:

BufferedReader br = new BufferedReader (new InputStreamReader (clientSocket.getInputStream (); PrintWriter pw = new PrintWriter (new OutputStreamWriter (clientSocket.getOutputStream (); while (true) {String buf = br.readLine (); System.out.println (Thread.currentThread (). GetName () + "client:" + buf); if (buf.equals ("close")) {break } pw.println ("response:" + buf); pw.flush ();} System.out.println ("close client"); br.close (); pw.close (); clientSocket.close ()

Client:

BufferedReader br = new BufferedReader (new InputStreamReader (clientSocket.getInputStream (); PrintWriter pw = new PrintWriter (new OutputStreamWriter (clientSocket.getOutputStream (); while (true) {System.out.print ("client:"); String buf = sc.nextLine (); pw.println (buf); pw.flush () If (buf.equals ("close")) {break;} buf= br.readLine (); System.out.println ("server:" + buf); if (buf.equals ("close")) {break }} br.close (); pw.close (); sc.close (); clientSocket.close ()

In this way, it is more convenient for the server to send information to the client.

Thank you for reading, the above is the content of "Java how to use thread pool to achieve socket programming". After the study of this article, I believe you have a deeper understanding of how Java uses thread pool to achieve socket programming, and the specific use needs to be verified in practice. Here is, the editor will push for you more related knowledge points of the article, welcome to follow!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.