javaSocket多线程服务器源代码介绍

java Socket多线程需要我们不断的学习，在学习的时候我们就会发现在服务器的配置上有不少的问题。下面我们就来看看服务器源代码是如何编写的，以便大家更好的使用java Socket多线程。

 
 
 
  
  
  import java.io.BufferedReader;     
  
  import java.io.IOException;     
  
  import java.io.InputStreamReader;     
  
  import java.io.PrintWriter;     
  
  import java.net.ServerSocket;     
  
  import java.net.Socket;     
  
  import java.util.ArrayList;     
  
  import java.util.List;     
  
  import java.util.concurrent.ExecutorService;     
  
  import java.util.concurrent.Executors;     
  
  public class ChatServer {     
  
  private static final int PORT = 1234; // 端口号     
  
  private static List list = new ArrayList(); 
// 保存连接对象     
  
  private ExecutorService exec;     
  
  private ServerSocket server;     
  
  public static void main(String[] args) {     
  
  new ChatServer();     
  
  }     
  
  public ChatServer() {     
  
  try {     
  
  server = new ServerSocket(PORT);     
  
  exec = Executors.newCachedThreadPool();     
  
  System.out.println(“服务器已启动！”);     
  
  Socket client = null;     
  
  while (true) {     
  
  client = server.accept(); // 接收客户连接     
  
  list.add(client);     
  
  exec.execute(new ChatTask(client));     
  
  }     
  
  } catch (IOException e) {     
  
  e.printStackTrace();     
  
  }     
  
  }     
  
  static class ChatTask implements Runnable {     
  
  private Socket socket;     
  
  private BufferedReader br;     
  
  private PrintWriter pw;     
  
  private String msg;     
  
  public ChatTask(Socket socket) throws IOException {     
  
  this.socket = socket;     
  
  br = new BufferedReader(new InputStreamReader(socket     
  
  .getInputStream()));     
  
  msg = “【” + this.socket.getInetAddress() + “】
进入聊天室！当前聊天室有【”     
  
  + list.size() + “】人”;     
  
  sendMessage();     
  
  }     
  
  public void run() {     
  
  try {     
  
  while ((msg = br.readLine()) != null) {     
  
  if (msg.trim().equals(“bye”)) {     
  
  list.remove(socket);     
  
  br.close();     
  
  pw.close();     
  
  msg = “【” + socket.getInetAddress() + “】
离开聊天室！当前聊天室有【”     
  
  + list.size() + “】人”;     
  
  socket.close();     
  
  sendMessage();     
  
  break;     
  
  } else {     
  
  msg = “【” + socket.getInetAddress() + “】说：” + msg;     
  
  sendMessage();     
  
  }     
  
  }     
  
  } catch (IOException e) {     
  
  e.printStackTrace();     
  
  }     
  
  }     
  
  /**     
  
  * 群发消息给聊天室的所有人     
  
  */     
  
  private void sendMessage() throws IOException {     
  
  System.out.println(msg);     
  
  for (Socket client : list) {     
  
  pw = new PrintWriter(client.getOutputStream(), true);     
  
  pw.println(msg);     
  
  }     
  
  }     
  
  }     
  
  }     
  
  import java.io.BufferedReader;     
  
  import java.io.InputStreamReader;     
  
  import java.io.PrintWriter;     
  
  import java.net.Socket;     
  
  import java.util.concurrent.ExecutorService;     
  
  import java.util.concurrent.Executors;     
  
  public class ChatClient {     
  
  private static final int PORT = 7891;     
  
  private static ExecutorService exec = 
Executors.newCachedThreadPool();     
  
  public static void main(String[] args) throws Exception {     
  
  new ChatClient();     
  
  }     
  
  public ChatClient() {     
  
  try {     
  
  Socket socket = new Socket(“221.130.165.41″, PORT);     
  
  exec.execute(new Sender(socket));     
  
  System.out.println(“【” + socket.getInetAddress() + “】
您好，欢迎来到简易聊天室！”);     
  
  BufferedReader br = new BufferedReader(new 
InputStreamReader(socket.getInputStream()));     
  
  String msg;     
  
  while ((msg = br.readLine()) != null) {     
  
  System.out.println(“收到—->”+msg);     
  
  }     
  
  } catch (Exception e) {     
  
  }     
  
  }

以上就是对java Socket多线程的相关介绍。

分享标题：javaSocket多线程服务器源代码介绍
文章地址：http://www.shufengxianlan.com/qtweb/news11/327261.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容