수다닷컴

서버가메시지를받고보내는데있어서1378번의메시지를읽고보낸후에더이상메시지를받지못합니다..
메모리테스트는전혀이상없엇구요..
카운트가멈춘후에클라이언트가접속했을때클라이언트접속이라는건뜨네요..죽지는않았는데메시지를못읽네요
서버소스인데요문제점을찾기가참힘드네요도움부탁드립니다. classTCPClient
{
Socketsocket;//소켓
InputStreamin;//소켓입력스트림
OutputStreamout;//소켓출력스트림

//생성자가실패할경우에는IOException을던진다.
TCPClient(Socketsocket)throwsIOException
{
this.socket=socket;

in=socket.getInputStream();
out=socket.getOutputStream();

socket.setSoTimeout(10);//타임아웃을설정(10milliseconds)
}

//입출력스트림과소켓을닫는다.
//예외는발생시키지않는다.
voidclose()
{
try{
in.close();
out.close();
socket.close();
}catch(IOExceptione){}
}
} publicclassServerextendsThread//TCP서버클래스
{
privatestaticfinalintBUFSIZE=24;//Sizeofreceivebuffer
intrecvMsgSize;
byte[]byteBuffer=newbyte[BUFSIZE];
ServerSocketserver_socket;//서버소켓
Vectorclient_list;
booleanactive;//서버가작동중인가?
Stringtemp;
inti=0;

//서버를처리한다.
voidprocess()
{
try
{
server_socket=newServerSocket(9000);//9000포트로서버소켓생성
client_list=newVector();//클라이언트리스트를보관
active=true;//서버가동시작
start();//클라이언트처리쓰레드가동

//메인프로그램쓰레드는소켓접속을기다린다.
while(true)
{
Socketclntsock=server_socket.accept();
//accept해서접속한소켓을클라이언트리스트에집어넣는다.
client_list.addElement(newTCPClient(clntsock));

System.out.println(Handlingclientat+clntsock.getInetAddress().getHostAddress()+onport+clntsock.getPort());
}
}
catch(Exceptione)
{
e.printStackTrace();
}
finally//최종적으로소켓을닫고쓰레드를정지시킨다.
&nbsbsp;{
//서버소켓을닫는다.
if(server_socket==null)
{
try{server_socket.close();}catch(Exceptione){}
active=false;//쓰레드종료
}
}
}

//메시지를브로드캐스팅한다.
intbroadcastMessage(byte[]byteBuffer)throwsIOException
{
//null메시지가넘어오면IOException을던진다.
if(byteBuffer==null)thrownewIOException(nullDATA!!!);

TCPClientclient;

//모든클라이언트에게메시지를전달한다.
for(Enumeratione=client_list.elements();e.hasMoreElements();)
{
client=(TCPClient)e.nextElement();
try{
//System.out.println(send);
client.out.write(byteBuffer,0,recvMsgSize);
}catch(Exceptionee){}
}
return0;
}

//클라이언트를처리하는쓰레드
publicvoidrun()
{
TCPClientclient;

while(active){//서버기동중에만
for(Enumeratione=client_list.elements();e.hasMoreElements();)
{
client=(TCPClient)e.nextElement();

try{

while((recvMsgSize=client.in.read(byteBuffer))!=-1){

System.out.println(i);
i++;
broadcastMessage(byteBuffer);//메시지를모두에게전송
}

}catch(InterruptedIOExceptionie){}//타임아웃에서발생한예외는처리하지않는다.

catch(Exceptionee){//나머지예외가발생하면리스트에서제거하고소켓을닫는다.
//예외는SocketExcetion이나IOException일것이다.
try{
client_list.removeElement(client);//리스트에서제거
client.close();//소켓을닫는다.
}catch(Exceptioneee){}
}
}
}

//쓰레드가종료되었으므로모든소켓을닫는다.
for(Enumeratione=client_list.elements();e.hasMoreElements();)
{
client=(TCPClient)e.nextElement();
client.close();
}
}

publicstaticvoidmain(String[]args)
{
Serverserver=newServer();//서버객체생성
server.process();//서버처리
}

신청하기