Go语言视频零基础入门到精通

javalearner

客户端程序:(其它程序请下载!!)

1. package com.tcl.chat;
   
2. import java.io.BufferedReader;
   
3. import java.io.IOException;
   
4. import java.io.InputStreamReader;
   
5. import java.net.InetSocketAddress;
   
6. import java.nio.ByteBuffer;
   
7. import java.nio.channels.SocketChannel;
   
8. import java.util.logging.Level;
   
9. import java.util.logging.Logger;
   
10. import com.tcl.chat.impl.ChatRecordStorageImpl;
    
11. public class ChatClient implements Runnable{
    
12.         private Logger log = Logger.getLogger(ChatClient.class.getName());
    
13.     SocketChannel mChannel;
    
14.     boolean bRunFlag = true;
    
15.     private boolean bIsInit = false;
    
16.     String mHostname;
    
17.     int  mPort;
    
18.    
    
19.     private ChatRecordStorage mChatStorage = new ChatRecordStorageImpl();
    
20.    
    
21.     public ChatClient(String host,int port){
    
22.             mHostname = host;
    
23.             mPort = port;
    
24.     }
    
25.     private static final int TRY_TIMES = 3;
    
26.         public void init() throws IOException{
    
27.                         mChannel =  SocketChannel.open();
    
28.                         mChannel.configureBlocking(false);  
    
29.                         mChannel.connect(new InetSocketAddress(mHostname,mPort));
    
30.                         int i = 0;
    
31.                         boolean error = false;
    
32.                         while (!mChannel.finishConnect() ) {
    
33.                                 if (i >= TRY_TIMES) {
    
34.                                         error = true;
    
35.                                         break;
    
36.                                 }
    
37.                                 i++;
    
38.                                 //
    
39.                                 try {
    
40.                                         Thread.sleep(200);
    
41.                                 } catch (InterruptedException e) {
    
42.                                         // TODO Auto-generated catch block
    
43.                                         e.printStackTrace();
    
44.                                 }
    
45.                         }
    
46.                         if (error) {
    
47.                                 throw new IOException("连接错误，稍后再试");
    
48.                         }
    
49.                         bIsInit = true;
    
50.         }
    
51.        
    
52.         @Override
    
53.         public void run() {
    
54.                 try {
    
55.                         init();
    
56.                        
    
57.                 } catch (IOException e) {
    
58.                         e.printStackTrace();
    
59.                         System.exit(0);
    
60.                 }
    
61.                 if (!bIsInit) {
    
62.                         throw new RuntimeException("not init");
    
63.                 }
    
64.                 ByteBuffer buffer = ByteBuffer.allocate(1024);
    
65.                 KeyBordReader kbr = new KeyBordReader();
    
66.                 new Thread(kbr).start();//阻塞方式的读
    
67.                
    
68.                 while (bRunFlag) {
    
69.                         buffer.clear();
    
70.                         StringBuffer sb = new StringBuffer();
    
71.                         int num;
    
72.                         try {
    
73.                                 Thread.sleep(500);
    
74.                                 while((num = mChannel.read(buffer)) > 0){
    
75.                                         sb.append(new String(buffer.array(),0,num));
    
76.                                         buffer.clear();
    
77.                                 }
    
78.                                 if (sb.length() > 0 ) {
    
79.                                         log.log(Level.INFO,"Client Recerive:" + sb.toString());
    
80.                                 }
    
81.                                 if (sb.toString().toLowerCase().trim().equals("bye")) {
    
82.                                         mChannel.close();
    
83.                                         kbr.close();
    
84.                                         bRunFlag = false;
    
85.                                         System.exit(0); //退出
    
86.                                 }
    
87.                         } catch (IOException e) {
    
88.                                 // TODO Auto-generated catch block
    
89.                                 e.printStackTrace();
    
90.                         } catch (InterruptedException e) {
    
91.                                 // TODO Auto-generated catch block
    
92.                                 e.printStackTrace();
    
93.                         }
    
94.                        
    
95.                 }
    
96.         }
    
97.         public static void main(String[] args) {
    
98.                 int port = 10003;
    
99.                 new Thread(new ChatClient("localhost", port)).start();
    
100.         }
     
101.        
     
102.         class KeyBordReader implements Runnable{
     
103.                 public KeyBordReader(){
     
104.                        
     
105.                 }
     
106.                 private boolean bRunFlag = true;
     
107.                 public void close(){
     
108.                         bRunFlag = false;
     
109.                 }
     
110.                 @Override
     
111.                 public void run() {
     
112.                         BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
     
113.                         while (this.bRunFlag) {
     
114.                                 //System.out.println(TIP);
     
115.                                 try {
     
116.                                         String str = reader.readLine().trim();
     
117.                                         if (str == null) {
     
118.                                                 continue;
     
119.                                         }
     
120.                                         if (!str.startsWith("@")) {
     
121.                                                 System.out.println("must begin with @");
     
122.                                                 continue;
     
123.                                         }else if (str.equals("@help")) {
     
124.                                                 System.out.println(TIP);
     
125.                                         }else if (str.equals("@exit")) {
     
126.                                                 System.exit(0);
     
127.                                         }
     
128.                                         mChannel.write(ByteBuffer.wrap(str.getBytes()));
     
129.                                 } catch (IOException e) {
     
130.                                         // TODO Auto-generated catch block
     
131.                                         e.printStackTrace();
     
132.                                 }
     
133.                                
     
134.                         }
     
135.                 }
     
136.                
     
137.         }
     
138.         private static String TIP = ""
     
139.                                                 + "@pub to send public message
140. "
     
141.                                                 + "@xxx to send private message
142. "
     
143.                                                 + "@exit to exit client
144. "
     
145.                                                 + "@quit to quit from server
146. "
     
147.                                                 + "@listmember to list members";
     
148.                        
     
149. }
     

复制代码

   
     
     
      
      

        
      

        
      
     
   

  


源码下载：http://file.javaxxz.com/2014/11/2/235821640.zip