三步学会Java Socket编程 - JAVA

;
}

public void run()
{
try
{
String line = in.readLine();

while (!line.equals("bye"))
{
String msg = createMessage(line);
out.println(msg);
line = in.readLine();
}
out.println("--- See you, bye! ---");
client.close();
}
catch (IOException e)
{}
}

private String createMessage(String line)
{
xxxxxxxxx;
}
}

public static void main(String[] args) throws IOException
{
new Server();
}
}

　　这个程序监听10000端口，并将接入交给CreateServerThread线程运行。CreateServerThread线程接受输入，并将输入回应客户，直到客户输入"bye"，线程结束。我们可以在createMessage方法中，对输入进行处理，并产生结果，然后把结果返回给客户。
第三步实现信息共享:在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 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 = (Cre <script type="text/java script">

点击复制链接与好友分享! 回本站首页

分享到：更多

您对本文章有什么意见或着疑问吗？请到论坛讨论您的关注和建议是我们前行的参考和动力

上一篇： 技术大潮中不迷失方向！J2EE修炼之四书五经

下一篇： 利用Socket进行Java网络编程

一篇不错的介绍Java Socket 编程的文章

Java中的Socket编程

Java Socket编程（一） Socket传输模式

Java Socket编程（二） Java面向连接

Java Socket编程（三）服务器Sockets

Java Socket编程（四）重复和并发服

Java Socket编程（五）简单的WEB服务器