网络编程问题

Question

此回复为自动发出,仅用于显示而已，并无任何其他特殊作用
楼主【gzf30】截止到2008-06-30 10:27:11的历史汇总数据(不包括此帖)：
发帖数:7                  发帖分:130                
结贴数:4                  结贴分:70                 
未结数:3                  未结分:60                 
结贴率:57.14 %            结分率:53.85 %            
楼主加油

Answer 1

为什么NBTest打印出sk.isAcceptable()的值为false？怎么样它的值才能为true?1  你 注册的是acceptable  有请求 才会是 TRUE、

Answer 2

public   class   ChatServer   { private   int   port   =   13; private   Selector   selector; private   ServerSocketChannel   ssc; private   ServerSocket   server; private   InetSocketAddress   address; private   HashMap <String,   SelectionKey>   userlist   =   new   HashMap <String,   SelectionKey> (); private   List   alluser   =   new   ArrayList <String> (); private   HashMap <String,   StringBuilder>   messagelist   =   new   HashMap <String,   StringBuilder> (); //   SelectionKey> (); public   ChatServer()   { 
//   initServer 
//   this.sc   =   sc; 
try   { 
ssc   =   ServerSocketChannel.open(); 
server   =   ssc.socket(); 
address   =   new   InetSocketAddress(port); 
server.bind(address); 
selector   =   Selector.open(); 
ssc.configureBlocking(false); 
ssc.register(selector,   SelectionKey.OP_ACCEPT); 
System.out.println( "Listening   the   port   13... "); 
}   catch   (IOException   ex)   { 
ex.printStackTrace(); 
System.exit(-1); 
} 
} public   void   sendmessage(SelectionKey   sk,   StringBuilder   message)   { 
try   { 
SocketChannel   sc   =   (SocketChannel)   sk.channel(); 
ByteBuffer   tbuffer   =   ByteBuffer.wrap(message.toString().getBytes()); 
while   (tbuffer.hasRemaining()   &   sc.write(tbuffer)   !=   -1) 
; 
}   catch   (Exception   e)   { 
e.printStackTrace();//   TODO:   handle   exception 
} 
} public   void   startServer()   throws   IOException   { 
while   (true)   { 
int   i   =   selector.select(); Iterator   keys   =   selector.selectedKeys().iterator(); while   (keys.hasNext())   { 
SelectionKey   key   =   (SelectionKey)   keys.next(); 
keys.remove(); 
try   { 
if   (key.isAcceptable())   { 
ServerSocketChannel   ssc   =   (ServerSocketChannel)   key 
.channel(); 
SocketChannel   channel   =   ssc.accept();//   return   null System.out.println(channel   +   "   has   accepted "); 
channel.configureBlocking(false); 
SelectionKey   clientKey   =   channel.register(selector, 
SelectionKey.OP_READ); } 
if   (key.isWritable())   { if   (alluser.size()   >   0)   { 
String   user   =   (String)   key.attachment(); StringBuilder   message   =   messagelist.get(user); 
if   (!message.toString().equals( " "))   { 
sendmessage(key,   message); 
System.out.println( "write:   "   +   user   +   "   " 
+   message); } 
messagelist.remove(user); 
messagelist.put(user,   new   StringBuilder( " ")); 
} 
//   key.interestOps(SelectionKey.OP_READ|SelectionKey.OP_WRITE); } 
if   (key.isReadable())   { 
SocketChannel   channel   =   (SocketChannel)   key.channel(); 
ByteBuffer   buffer   =   ByteBuffer.allocate(50); channel.read(buffer); buffer.flip(); 
String   checkBuffer   =   this.decode(buffer); 
System.out.println( "read: "   +   checkBuffer); if   (checkBuffer.startsWith( "login   "))   { String   user   =   checkBuffer.substring(6,   checkBuffer 
.length()); 
System.out.println( "user:   "   +   user   +   "   login "); 
String   username   =   checkBuffer.substring(6, 
checkBuffer.length()); 
key.attach(user); 
userlist.put(user,   key); 
messagelist.put(user,   new   StringBuilder( "welcome   " 
+   user)); 
alluser.add(user); key.interestOps(SelectionKey.OP_WRITE 
|   SelectionKey.OP_READ); }   else   if   (checkBuffer.startsWith( "chat   "))   { String   message1   =   checkBuffer.substring(5); 
String   reveiver   =   message1.substring(0,   message1 
.indexOf( "   ")); 
String   message   =   message1.substring(message1 
.indexOf( "   ")   +   1,   message1.indexOf( "| ")); 
String   sender   =   message1.substring(message1 
.indexOf( "| ")   +   1,   message1.length()); String   message2   =   "[you-> "   +   reveiver   +   ":   " 
+   message   +   "]\n "; 
message   =   "[ "   +   sender   +   "-> you:   "   +   message 
+   "]\n "; messagelist.get(reveiver).append(message); 
messagelist.get(sender).append(message2); //   key.interestOps(SelectionKey.OP_WRITE); 
System.out.println( "read:   "   +   message); }   else   if   (checkBuffer.startsWith( "list "))   { String   reveiver   =   checkBuffer.substring(checkBuffer 
.indexOf( "| ")   +   1,   checkBuffer.length()); StringBuilder   list   =   new   StringBuilder( " "); 
Iterator <String>   it   =   alluser.iterator(); while   (it.hasNext())   { 
list.append( "[ "   +   it.next()   +   "]\n "); 
} 
list.append( "\n "); 
messagelist.get(reveiver).append(list); //   key.interestOps(SelectionKey.OP_WRITE); }   else   if   (checkBuffer.startsWith( "broadcast   "))   { 
String   broadcast   =   " "; 
String   message   =   checkBuffer 
.substring(checkBuffer.indexOf( "   ")   +   1, 
checkBuffer.indexOf( "| ")); 
String   user   =   checkBuffer.substring(checkBuffer 
.indexOf( "| ")   +   1,   checkBuffer.length()); 
broadcast   =   "[world( "   +   user   +   "): "   +   message 
+   "]\n "; Iterator <String>   it   =   alluser.iterator(); 
while   (it.hasNext())   { messagelist.get(it.next()).append(broadcast); 
} //   key.interestOps(SelectionKey.OP_WRITE); System.out.println( "read:   "   +   broadcast); }   else   if   (checkBuffer.startsWith( "logout "))   { 
String   broadcast   =   " "; String   user   =   checkBuffer.substring(7,   checkBuffer 
.length()); //   sc.logout(user); 
messagelist.remove(user); 
userlist.remove(user); 
String   message   =   " "; 
message   =   "[ "   +   user   +   "   see   you   next   time   ] "; 
System.out.println( "read:   "   +   message); 
SocketChannel   sc   =   (SocketChannel)   key.channel(); 
ByteBuffer   tbuffer   =   ByteBuffer.wrap(message 
.getBytes()); 
while   (tbuffer.hasRemaining() 
&   sc.write(tbuffer)   !=   -1) 
; key.cancel(); 
}   else   { 
String   message   =   checkBuffer.substring(0, 
checkBuffer.indexOf( "| ")); 
message   =   "[unknown   command ' "   +   message   +   " '] "; 
String   reveiver   =   checkBuffer.substring(checkBuffer 
.indexOf( "| ")   +   1,   checkBuffer.length()); 
messagelist.get(reveiver).append(message); System.out.println( "write:   "   +   message); } 
} 
}   catch   (IOException   ex)   { 
key.cancel(); 
try   { 
key.channel().close(); 
}   catch   (IOException   cex)   { 
} 
} 
} 
} 
} public   String   decode(ByteBuffer   buffer)   { 
Charset   charset   =   null; 
CharsetDecoder   decoder   =   null; 
CharBuffer   charBuffer   =   null; 
try   { 
charset   =   Charset.forName( "gb2312 "); 
decoder   =   charset.newDecoder(); 
charBuffer   =   decoder.decode(buffer); 
return   charBuffer.toString(); 
}   catch   (Exception   ex)   { 
ex.printStackTrace(); 
return   " "; 
} } public   static   void   main(String[]   args)   { ChatServer   cs   =   new   ChatServer(); try   { 
//   st.start(); 
cs.startServer(); }   catch   (IOException   ex)   { 
ex.printStackTrace(); 
System.exit(-1); 
} 
} 
} 
我写的 看看  测试过可以的