[Java]前辈请教导

伪君子

对了...
package .Com.xxx 的.Com 是什么来的?

lewisksh

會不會是還沒有set path ,所以不能用javac ?

example

setpath="c:/jkd1.5/bin/"

Netmercury

no time to see your code and no time to type in chinese, going out, but can simply give you an idea to do it.
use thread in server to listen for input, when the input is not null, then read the input and cast to client.
run two files separately, server is opening serversocket and client is socket to the server.
that's it.
hope this can help.
i am going out la, bb.

tensaix2j

楼上两位，一个没爬贴，一个读贴没看日期。。

tensaix2j

我也刚学java不久。。
这一贴然我很想尝试用java做个chat program.

tensaix2j

刚完成的 chat program.
.
楼主这一贴然我很想尝试用java做个chat program.
只是不知为何multicast不work，所以就用普通的stream socket..

我的方法是server把所有接到的client socket堆在一个arraylist里。。
然后每次拿到msg from任何一个socket，就iterate那个arraylist..
来write到各个socket..







现在，有个问题。。
如何让server知道client已经关掉了。。


client

1. 
   
2. import javax.swing.*;
   
3. import java.awt.event.*;
   
4. import java.net.*;
   
5. import java.io.*;
   
6. 
   
7. class myclient implements KeyListener
   
8. {
   
9.         //References
   
10.         JFrame fr;       
    
11.         JTextArea jta;       
    
12.         JTextArea jta2;
    
13.         JScrollPane jsp;
    
14.         JScrollPane jsp2;
    
15.         Socket s;
    
16.         InputStream inputS;
    
17.         OutputStream outputS;
    
18. 
    
19.                
    
20.         class ObtainMessage implements Runnable
    
21.         {
    
22.                 public void run()
    
23.                 {
    
24.                         for (;;)
    
25.                         {                       
    
26.                                 try
    
27.                                 {
    
28.                                         byte[] buflen=new byte[1];
    
29.                                         inputS.read(buflen,0,1);
    
30.                                         byte [] buf=new byte[buflen[0]];
    
31.                                         inputS.read(buf,0,buflen[0]);
    
32.                                         jta.append(new String(buf));
    
33.                                 }
    
34.                                 catch (Exception ex)
    
35.                                 {}
    
36.                                
    
37.                         }
    
38. 
    
39.                 }
    
40.         }
    
41. 
    
42. 
    
43.         public static void main(String args[])
    
44.         {
    
45.                 myclient mc=new myclient();
    
46.                
    
47.         }
    
48. 
    
49.         public myclient()
    
50.         {
    
51. 
    
52.                 fr=new JFrame("Client");
    
53.                 jta = new JTextArea();
    
54.                 jta2 = new JTextArea();
    
55.                 jsp= new JScrollPane(jta);
    
56.                 jsp2= new JScrollPane(jta2);
    
57. 
    
58.                 jsp.setBounds(10,10,270,200);
    
59.                 jsp2.setBounds(10,220,270,50);
    
60.                
    
61.                 fr.getContentPane().add(jsp);
    
62.                 fr.getContentPane().add(jsp2);
    
63.                
    
64.                 jta.setEditable(false);
    
65.                 jta2.addKeyListener(this);
    
66. 
    
67.                 fr.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    
68.                 fr.setBounds(50, 50, 300, 350);
    
69.                 fr.getContentPane().setLayout(null);
    
70.                 fr.setVisible(true);
    
71. 
    
72.                 try
    
73.                 {
    
74.                         s= new Socket("127.0.0.1",8000);
    
75.                         inputS= s.getInputStream();
    
76.                         outputS= s.getOutputStream();
    
77.                        
    
78.                         Thread listen= new Thread(new ObtainMessage());
    
79.                         listen.start();
    
80.                                                                                
    
81.                 }
    
82.                 catch (Exception ex)
    
83.                 {
    
84.                         System.out.println("no connection");
    
85.                 }
    
86.                        
    
87.         }
    
88. 
    
89.        
    
90. 
    
91.         public void keyReleased(KeyEvent e)
    
92.         {
    
93.                 switch(e.getKeyCode())
    
94.                 {
    
95.                         case KeyEvent.VK_ENTER:
    
96.                         {
    
97.                                 try
    
98.                                 {
    
99.                                         String buf=jta2.getText();
    
100.                                         byte[] len= {(byte)(buf.length() & 0xff)};
     
101.                                         outputS.write(len,0,1);
     
102.                                         outputS.write(buf.getBytes(),0,buf.length());
     
103.                                 }
     
104.                                 catch (Exception ex)
     
105.                                 {}
     
106.                                 jta2.setText("");
     
107.                                 break;
     
108.                         }
     
109.                 }
     
110.         }
     
111.         public void keyTyped(KeyEvent e){}
     
112.         public void keyPressed(KeyEvent e){}
     
113. 
     
114. }
     
115. 
     
116. 
     

复制代码

server

1. 
   
2. import java.net.*;
   
3. import java.io.*;
   
4. import java.util.*;
   
5. 
   
6. class myserver
   
7. {
   
8.        
   
9.         ServerSocket ss;
   
10.         ArrayList cl;
    
11.        
    
12.         myserver()
    
13.         {
    
14.                 try
    
15.                 {
    
16.                         ss=new ServerSocket(8000);
    
17.                         cl=new ArrayList();
    
18.                        
    
19.                         for (;;)  //Accept infinite clients
    
20.                         {
    
21.                                 try
    
22.                                 {
    
23.                                         Socket s= ss.accept();
    
24.                                         System.out.println("Someone is in");
    
25.                                         cl.add(s);
    
26.                                         System.out.println(cl.size() + " people are in");
    
27.                                        
    
28.                                         //Spawn new thread to handle new client
    
29.                                         Thread t=new Thread(new ClientHandler(s));
    
30.                                         t.start();
    
31.                                        
    
32.                                 }
    
33.                                 catch (Exception e)
    
34.                                 {}
    
35.                         }
    
36. 
    
37.                                
    
38.                                                
    
39.                 }
    
40.                 catch (Exception e)
    
41.                 {
    
42.                         System.out.println(e.toString());
    
43.                 }       
    
44. 
    
45.         }       
    
46. 
    
47.         public static void main(String args[])
    
48.         {
    
49.                 new myserver();
    
50.                                                
    
51.         }
    
52. 
    
53. 
    
54. 
    
55. 
    
56.        
    
57. 
    
58.         class ClientHandler implements Runnable
    
59.         {
    
60.                 Socket s;
    
61.                 InputStream inputS;
    
62.                
    
63.                 ClientHandler(Socket s)
    
64.                 {
    
65.                         try
    
66.                         {
    
67.                                 this.s=s;
    
68.                                 this.inputS = s.getInputStream();
    
69.                                
    
70.                         }
    
71.                         catch (Exception e)
    
72.                         {}
    
73.                        
    
74.                 }
    
75. 
    
76.                 public void run()
    
77.                 {
    
78.                         try
    
79.                         {
    
80.                                 for (;;)
    
81.                                 {
    
82.                                         byte[] buflen=new byte[1];
    
83.                                         inputS.read(buflen,0,1);
    
84.                                         byte [] buf=new byte[buflen[0]];
    
85.                                         inputS.read(buf,0,buflen[0]);
    
86.                                         System.out.print(new String(buf));
    
87.                                        
    
88.                                         int i;
    
89.                                         for (i=0;i<cl.size();i++)
    
90.                                         {
    
91. 
    
92.                                                 OutputStream outputS=((Socket)cl.get(i)).getOutputStream();
    
93.                                                 outputS.write(buflen,0,1);
    
94.                                                 outputS.write(buf,0,buflen[0]);
    
95. 
    
96.                                         }
    
97. 
    
98.                                        
    
99.                                        
    
100.                                 }                       
     
101.                         }
     
102.                         catch (Exception e)
     
103.                         {}
     
104. 
     
105.                 }
     
106.         }
     
107. 
     
108. 
     
109.                
     
110. 
     
111. 
     
112. }
     

复制代码

[ 本帖最后由 tensaix2j 于 22-10-2006 05:08 PM 编辑 ]