日本国产亚洲-日本国产一区-日本国产一区二区三区-日本韩国欧美一区-日本韩国欧美在线-日本韩国欧美在线观看

當前位置:雨林木風下載站 > 技術開發教程 > 詳細頁面

3步學會Java Socket編程(3)

3步學會Java Socket編程(3)

更新時間:2022-05-14 文章作者:未知 信息來源:網絡 閱讀次數:

第三步 實現信息共享:在Socket上的實時交流

  網絡的偉大之一也是信息共享,Server可以主動向所有Client廣播消息,同時Client也可以向其它Client發布消息。下面看看如何開發一個可以實時傳遞消息的程序。

  設計原理:

  服務器端接受客戶端的連接請求,同時啟動一個線程處理這個連接,線程不停的讀取客戶端輸入,然后把輸入加入隊列中,等候處理。在線程啟動的同時將線程加入隊列中,以便在需要的時候定位和取出。

  {源碼}


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 connection\015\012";
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 -+-\015\012";

for (int i = 0; i < User_List.size(); i++)
{
s += "[" + User_List.get(i) + "]\015\012";
}

s += "-+---------------------+-";
return s;
}

private void pushMessage(String msg)
{
Message_Array.addLast(msg);
isClear = false;
}
}
}



  這就是程序運行后,多用戶登陸并且輸入信息后的屏幕。實現了信息的實時廣播。用戶輸入"l"就可以列出在線人員表。

溫馨提示:喜歡本站的話,請收藏一下本站!

本類教程下載

系統下載排行

主站蜘蛛池模板: 日本久久久久亚洲中字幕 | 日韩精品欧美亚洲高清有无 | 国内精品久久久久影院老司 | 91欧美精品激情在线观看 | www深夜视频在线观看高清 | 91亚洲国产成人久久精品网址 | 久久久久久网址 | 伊人久久免费 | 一二三区在线观看 | 草免费视频| 色免费视频 | 久久五月女厕所一区二区 | 大伊香蕉精品视频在线天堂 | 欧美日韩精品国产一区在线 | 国产亚洲欧洲国产综合一区 | 99热久久是国产免费66 | 天天cao在线| 精品区 | 日韩一二三 | 色老板在线观看永久免费视频 | 成人一区专区在线观看 | 毛片资源网 | 日韩成人免费一级毛片 | 欧美一级视频在线观看欧美 | 99热精品在线 | 精品福利视频网站 | 国产片国语版 | 天天爽夜夜爽人人爽曰喷水 | 天天影视欲香欲色成人网 | 日本人与zozoxxxx视频 | 日韩免费毛片视频 | 美日韩一区二区 | 四虎影视大全 | 超91精品手机国产在线 | 伊人热久久 | 日本边摸边吃奶边做免费观看 | 色www永久免费网站国产 | 国产91一区二这在线播放 | 天天搞天天 | 国产精品二区高清在线 | 国产精品天干天干在线综合 |