Java Socket線程我們經(jīng)常會(huì)用到的技術(shù)，但是有很多程序員還是有不少的使用問題，下面我們就看看如何才能進(jìn)行有關(guān)的代碼編寫，希望大家又說收獲。網(wǎng)絡(luò)的偉大之一也是信息共享，Server可以主動(dòng)向所有Client廣播消息，同時(shí)Client也可以向其它Client發(fā)布消息。

下面看看如何開發(fā)一個(gè)可以實(shí)時(shí)傳遞消息的程序。

Java Socket線程的設(shè)計(jì)原理：

服務(wù)器端接受客戶端的連接請求，同時(shí)啟動(dòng)一個(gè)線程處理這個(gè)連接，線程不停的讀取客戶端輸入，然后把輸入加入隊(duì)列中，等候處理。在線程啟動(dòng)的同時(shí)將線程加入隊(duì)列中，以便在需要的時(shí)候定位和取出。

{源碼｝

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線程的詳細(xì)介紹。這就是程序運(yùn)行后，多用戶登陸并且輸入信息后的屏幕。實(shí)現(xiàn)了信息的實(shí)時(shí)廣播。用戶輸入"l"就可以列出在線人員表。

【編輯推薦】

1. Java Socket編程關(guān)鍵代碼詳解
2. java Socket多線程服務(wù)器源代碼介紹
3. java Socket多線程客戶端配置方案
4. Java Socket通訊實(shí)際操作手冊
5. Java Socket通訊客戶端代碼編寫教程