知识大全 Java Socket线程的设计原理介绍

Posted 2022-07-19 知

篇首语：农村四月闲人少，勤学苦攻把名扬。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Java Socket线程的设计原理介绍相关的知识，希望对你有一定的参考价值。

Java Socket线程的设计原理介绍 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

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

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

　　Java Socket线程的设计原理

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

　　源码｝

　　 import java io *;

　　 import *;

　　 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 = ;

　　 private static boolean isClear = true;

　　 protected static final int SERVER_PORT = ;

　　 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 connection ;

　　 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 = ; i < Threader size(); i++)

　　 CreateServerThread client = (CreateServerThread)Threader get(i);

　　 client sendMessage(tmp);

　　 Message_Array removeFirst();

　　 isClear = Message_Array size() > ? 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( Wele to this chatroom );

　　 out println( Input your nickname: );

　　 start();

　　 public void sendMessage(String msg)

　　 out println(msg);

　　 public void run()

　　 try

　　 int flag = ;

　　 Thread_Counter++;

　　 String line = in readLine();

　　 while (!line equals( bye ))

　　 if (line equals( l ))

　　 out println(listOnlineUsers());

　　 line = in readLine();

　　ntinue;

　　 if (flag++ == )

　　 Username = line;

　　 User_List add(Username);

　　 out println(listOnlineUsers());

　　 Threader add(this);

　　 pushMessage( [< + Username + e 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 + ;

　　 for (int i = ; i < User_List size(); i++)

　　 s += [ + User_List get(i) + ] ;

　　 s += + + ;

　　 return s;

　　 private void pushMessage(String msg)

　　 Message_Array addLast(msg);

　　 isClear = false;

cha138/Article/program/Java/hx/201311/25686