Java Socket线程的设计原理介绍

Java Socket线程我们经常会用到的技术，但是有很多程序员还是有不少的使用问题，下面我们就看看如何才能进行有关的代码编写，希望大家又说收获。网络的伟大之一也是信息共享，Server可以主动向所有Client广播消息，同时Client也可以向其它Client发布消息。

成都创新互联公司是一家以成都网站建设公司、网页设计、品牌设计、软件运维、网站推广、小程序App开发等移动开发为一体互联网公司。已累计为成都格栅板等众行业中小客户提供优质的互联网建站和软件开发服务。

下面看看如何开发一个可以实时传递消息的程序。

Java Socket线程的设计原理：

服务器端接受客户端的连接请求，同时启动一个线程处理这个连接，线程不停的读取客户端输入，然后把输入加入队列中，等候处理。在线程启动的同时将线程加入队列中，以便在需要的时候定位和取出。

{源码｝

 
 
   
  
  import java.io.*;     
  
  import java.net.*;     
  
  import java.util.*;     
  
  import java.lang.*;     
  
  public class Server extends ServerSocket     
  
  {     
  
  private static ArrayList User_List = new ArrayList();     
  
  private static ArrayList Threader = new ArrayList();     
  
  private static LinkedList Message_Array = new LinkedList();     
  
  private static int Thread_Counter = 0;     
  
  private static boolean isClear = true;     
  
  protected static final int SERVER_PORT = 10000;     
  
  protected FileOutputStream LOG_FILE = new FileOutputStream("d:/connect.log", true);     
  
  public Server() throws FileNotFoundException, IOException     
  
  {     
  
  super(SERVER_PORT);     
  
  new Broadcast();     
  
  //append connection log     
  
  Calendar now = Calendar.getInstance();     
  
  String str = "[" + now.getTime().toString() + "] Accepted a connection1512";     
  
  byte[] tmp = str.getBytes();     
  
  LOG_FILE.write(tmp);     
  
  try     
  
  {     
  
  while (true)     
  
  {     
  
  Socket socket = accept();     
  
  new CreateServerThread(socket);     
  
  }     
  
  }     
  
  finally     
  
  {     
  
  close();     
  
  }     
  
  }     
  
  public static void main(String[] args) throws IOException     
  
  {     
  
  new Server();     
  
  }     
  
  //--- Broadcast     
  
  class Broadcast extends Thread     
  
  {     
  
  public Broadcast()     
  
  {     
  
  start();     
  
  }     
  
  public void run()     
  
  {     
  
  while (true)     
  
  {     
  
  if (!isClear)     
  
  {     
  
  String tmp = (String)Message_Array.getFirst();     
  
  for (int i = 0; i < Threader.size(); i++)     
  
  {     
  
  CreateServerThread client = (CreateServerThread)Threader.get(i);     
  
  client.sendMessage(tmp);     
  
  }    
  
  Message_Array.removeFirst();     
  
  isClear = Message_Array.size() > 0 ? false : true;     
  
  }     
  
  }     
  
  }     
  
  }     
  
  //--- CreateServerThread     
  
  class CreateServerThread extends Thread     
  
  {     
  
  private Socket client;     
  
  private BufferedReader in;     
  
  private PrintWriter out;     
  
  private String Username;     
  
  public CreateServerThread(Socket s) throws IOException     
  
  {     
  
  client = s;     
  
  in = new BufferedReader(new InputStreamReader(client.getInputStream()));     
  
  out = new PrintWriter(client.getOutputStream(), true);     
  
  out.println("--- Welcome to this chatroom ---");     
  
  out.println("Input your nickname:");     
  
  start();     
  
  }     
  
  public void sendMessage(String msg)     
  
  {     
  
  out.println(msg);     
  
  }     
  
  public void run()     
  
  {     
  
  try     
  
  {     
  
  int flag = 0;     
  
  Thread_Counter++;     
  
  String line = in.readLine();     
  
  while (!line.equals("bye"))     
  
  {     
  
  if (line.equals("l"))     
  
  {     
  
  out.println(listOnlineUsers());     
  
  line = in.readLine();     
  
  continue;     
  
  }     
  
  if (flag++ == 0)     
  
  {     
  
  Username = line;     
  
  User_List.add(Username);     
  
  out.println(listOnlineUsers());     
  
  Threader.add(this);     
  
  pushMessage("[< " + Username + " come on in >]");     
  
  }     
  
  else     
  
  {     
  
  pushMessage("<" + Username + ">" + line);     
  
  }     
  
  line = in.readLine();     
  
  }     
  
  out.println("--- See you, bye! ---");     
  
  client.close();     
  
  }     
  
  catch (IOException e)     
  
  {}     
  
  finally     
  
  {     
  
  try     
  
  {    
  
  client.close();     
  
  }     
  
  catch (IOException e)     
  
  {}     
  
  Thread_Counter--;     
  
  Threader.remove(this);     
  
  User_List.remove(Username);     
  
  pushMessage("[< " + Username + " left>]");     
  
  }     
  
  }     
  
  private String listOnlineUsers()     
  
  {     
  
  String s ="-+- Online list -+-1512";     
  
  for (int i = 0; i < User_List.size(); i++)     
  
  {     
  
  s += "[" + User_List.get(i) + "]1512";     
  
  }     
  
  s += "-+---------------------+-";     
  
  return s;     
  
  }     
  
  private void pushMessage(String msg)     
  
  {     
  
  Message_Array.addLast(msg);     
  
  isClear = false;     
  
  }     
  
  }     
  
  }

以上就是对Java Socket线程的详细介绍。这就是程序运行后，多用户登陆并且输入信息后的屏幕。实现了信息的实时广播。用户输入"l"就可以列出在线人员表。

【编辑推荐】

Java Socket编程关键代码详解
java Socket多线程服务器源代码介绍
java Socket多线程客户端配置方案
Java Socket通讯实际操作手册
Java Socket通讯客户端代码编写教程

当前名称：Java Socket线程的设计原理介绍
文章转载：http://www.shufengxianlan.com/qtweb/news38/256038.html

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

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

猜你还喜欢下面的内容