listenserve.java

使用java实现的基于tcp通信协议的一个聊天程序的服务端

import java.io.*; 
import java.lang.*; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.net.SocketException;
 
public class listenserve 
{ 
private ServerSocket ss; 
private boolean listening=true; 
public listenserve() 
{ 
Init();//初始化 
lisn();//启动监听 
} 
public void Init() 
{ 
try 
{ 
ss=new ServerSocket(10015,10); 
} 
catch(IOException ie) 
{ 
System.out.println("无法在10015端口监听"); 
ie.printStackTrace(); 
} 
} 
public void lisn() 
{ 
try 
{ 
while(listening) 
new Thread(new dialogserve(ss.accept())).start(); 
} 
catch(IOException ie) 
{ie.printStackTrace();} 
} 
public static void main(String args[]) 
{ 
new listenserve(); 
} 
} 
class dialogserve implements Runnable 
{ 
private Socket s; 
private InputStream in; 
private String rev,temp; 
private byte b[]; 
private int len; 
public dialogserve(Socket ss) 
{ 
s=ss; 
b=new byte[1024]; 
try 
{ 
in=s.getInputStream(); 
}catch(IOException ie) 
{ 
ie.printStackTrace(); 
} 
rev=""; 
} 
public void run() 
{ 
try 
{ 
while(s.isConnected()==true) 
{ 
if((len=in.read(b))!=-1) 
{ 
temp=new String(b,0,len); 
rev+=temp; 
System.out.print(rev); 
temp=null; 
Thread.sleep(1000); 
} 
} 
in.close(); 
s.close(); 
System.out.println("会话socket已断开！"); 
} 
catch(SocketException se) 
{ 
System.out.println("客户端已断开！"); 
System.exit(0); 
} 
catch(IOException io) 
{ 
io.printStackTrace(); 
System.exit(0); 
} 
catch(InterruptedException ire) 
{ ire.printStackTrace();} 
} 
}