发信人: zy_xxyl(猩猩月亮)
整理人: zjxyz(2001-12-18 16:15:27), 站内信件
|
◆用JAVA实现并发SOCKET通信
如果以前做过C的SOCKET编程，那么这一段对你来说将不是什么难事。利用JAVA的多线程机制我们可以非常方便的实现并发服务。
每当我们知道服务器主程序创建一个新的套接字连接（即成功地调用了accept（）方法）的时候，就启动一个新的线程来负责本服务器和该客户之间的连接，主程序将返回并等待下一个连接。为了实现这个方案，本服务器主循环应该采用如下形式：
while(true)
{ Socket newjoin=s.accept();
Tread t=new ThreadedChatHandle(newjoin);
t.start();
}
ThreadedChatHandle类是从Thread类衍生出的处理聊天过程的子类，它的run（）方法包括了服务器和客户的通信循环――判断客户的请求（例如登录、发言、刷新在线列表），处理发言数据，发送聊天信息等等。下面是一个服务器程序的例子，可以帮助初学者尽快理解。
import java.io.*;
import java.net.*;
public class ChatServer
{ public static void main(String[] args)
{ int I=1;
try
{ServerSocket s=new ServerSocket(8080);
/*创建一个监视8080端口的服务器套接字，如果需要，你可以改成80端口*/
for(;;)
{ Socket newjoin=s.accept();
/*等待一个连接。如果这个连接没有被创建，本方法阻塞当前线程。返回值是一个
Socket对象，服务器程序利用这个对象可以与连接的客户通信。*/
System.out.println(“新连接”+i);
new ThreadedChatHandle(newjoin,i).start();
/* ThreadedChatHandle(Socket theS,int c)是我们自己定义的聊天服务类，这个
类在后边我们有进一步描述*/
i++;
}
}
catch(Exception e)
{ System.out.println(e);
}
}
……
}
多进程（线程）并发服务的一个关键问题是，如何实现进程（线程）间通信。每个客户的发言（包括表情和动作等选项）都需要放在一个公共的地方，让所有的输出线程都能够获得它。解决的方法有很多，比如说放在数据库里，放在大家都有权限的dat文件里，或直接用管道实现进程间通信。其中，对一个聊天室服务器来说，第一种方法是最傻的，太消耗系统资源，而且使程序执行效率变慢，可能出错环节增多。而使用管道通信的方式，把所有发言数据都保存在内存里，不但可以获得最高的执行效率，安全的执行过程，也不用考虑线程同步的问题。不要以为所有的发言数据会很多，其实服务器端只要保存最后100句就已经很了不起了，不是吗？
JAVA里关于管道的API有：
●Java.io.PipedInputStream
PipldInputStream()：
创建新的管道输入流，且它没有关联一个管道输出流。
PipldInputStream(PipldOutputStream out)：
创建新的管道输入流，且从管道输出流out中读取数据。
connect(PipldOutputStream out)：
关联一个管道输出流，且这个流读取数据。
●Java.io.PipedOutputStream
PipldOutputStream()：
创建新的管道输出流，且它没有关联一个管道输入流。
PipldOutputStream(PipldInputStream in)：
创建新的管道输出流，并输出数据到in。
connect(PipldInputStream in)：
关联一个管道输入流，并输入数据到in。
◆Daemon的实现
实际上，我还没有找到直接在JAVA中实现后台守护进程的方法。实现一个后台进程需要完成一系列的工作，包括：关闭所有的文件描述字；改变当前工作目录；重设文件存取屏蔽码(umask) ；在后台执行；脱离进程组；忽略终端I/O信号；脱离控制终端。
JAVA中有一个叫Daemon Thread的东西，我没有使用过。据介绍，这种叫服务线程的东东唯一的目的就是为其它线程提供服务。而一个程序里如果只剩下服务线程的话，这个程序就会停止（和我们的初衷简直就是南辕北辙）。有兴趣的朋友可以看看相关的内容，在java.lang.Thread.setDaemon()。
虽然我们不能用JAVA实现后台服务守护进程，不过我们还有JAVA的C接口，问题总有解决的办法。
◆异常处理
在Socket通信过程中很容易出现一些意外情况，如果不加处理直接发送数据，就可能导致程序意外退出。例如，客户关闭了socket后，服务器继续发送数据，这就会导致异常。为避免这一情况的发生，我们必须对它进行处理，一般情况下，只需要简单地忽略这个信号就可以了。幸好，JAVA的异常处理机制还比较强壮。
◆用户断线判断和处理
许多情况下，用户不是通过提交“离开”按钮离开聊天室，这时候就需要判断用户是否断线了。一般用户断线可能包括以下几种情况：方法是：当用户关闭浏览器，或者点击了浏览器stop按钮，或者跳转到其他网页的时候（如果用JAVASCRIPT弹出一个聊天窗口的话，那么这两种情况我们是能够避免的――大不了再禁止右键），相对应的socket将会变成可读状态，而此时读出的数据却是空字符串。
利用这个原理，只要在某个可读的socket读取数据时，读到的却是空数据，那么我们就可以断定，与这个socket相对应的用户断线了。
◆防止连接超时断线
如果浏览器在一段时间内没有接到任何数据，那么就会出现超时错误。要避免这一错误，必须在一定间隔内发送一些数据，在我们这个应用系统里，可以发送一些html注释。发送注释的工作可以直接插入聊天内容之间来完成
******转自cnjavaclub******
|
|