1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. public class TransTextDemo {
   
5. 
   
6.         /**
   
7.          * @param args
   
8.          * @throws Exception
   
9.          */
   
10.         public static void main(String[] args) throws Exception {
    
11.                 // TODO Auto-generated method stub
    
12.                 Socket s = new Socket("127.0.0.1",10006);
    
13.                 ServerSocket ss = new ServerSocket(10006);
    
14.                
    
15.                 new Thread(new TransServer(ss)).start();
    
16.                 new Thread(new TransClient(s)).start();
    
17.         }
    
18. 
    
19. }
    
20. 
    
21. class TransClient implements Runnable{
    
22.         private Socket s;
    
23.         TransClient(Socket s){
    
24.                 this.s = s;
    
25.         }
    
26.         public void run(){
    
27.                 //定义读取键盘数据的流对象
    
28.                 BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
    
29.                
    
30.                 try {
    
31.                         //定义目的,将数据写入到socket输出流,发给服务端
    
32.                         PrintWriter out = new PrintWriter(s.getOutputStream(),true);
    
33.                         
    
34.                         //定义一个socket读取流,读取服务端返回的数据
    
35.                         BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    
36.                         
    
37.                         String line = null;
    
38.                         while((line=bufr.readLine())!=null){
    
39.                                 if("over".equals(line)){
    
40.                                         break;
    
41.                                 }
    
42.                                 out.println(line);
    
43.                                 String str = bufIn.readLine();
    
44.                                 System.out.println("server:"+str);
    
45.                         }
    
46.                         bufr.close();
    
47.                         s.close();
    
48.                 } catch (IOException e) {
    
49.                         // TODO Auto-generated catch block
    
50.                         e.printStackTrace();
    
51.                 }
    
52.         }
    
53. }
    
54. 
    
55. class TransServer implements Runnable{
    
56.         private ServerSocket ss;
    
57.         TransServer(ServerSocket ss){
    
58.                 this.ss = ss;
    
59.         }
    
60.         
    
61.         public void run(){
    
62.                 try {
    
63.                         Socket s = ss.accept();
    
64.                         
    
65.                         //读取socket流中的数据
    
66.                         BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    
67.                         
    
68.                         //目的,socket输出流,将大写数据写入到socket输出流,并发送给客户端
    
69.                         
    
70.                         PrintWriter out = new PrintWriter(s.getOutputStream(),true);
    
71.                         String line =null;
    
72.                         while((line=bufIn.readLine())!=null){
    
73.                                 out.println(line);
    
74.                         }
    
75.                         s.close();
    
76.                         ss.close();
    
77.                 } catch (IOException e) {
    
78.                         // TODO Auto-generated catch block
    
79.                         e.printStackTrace();
    
80.                 }
    
81.         }
    
82. }
    

复制代码

提示:

1. Exception in thread "main" java.net.ConnectException: Connection refused: connect
   
2.         at java.net.DualStackPlainSocketImpl.connect0(Native Method)
   
3.         at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:69)
   
4.         at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
   
5.         at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
   
6.         at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
   
7.         at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:157)
   
8.         at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
   
9.         at java.net.Socket.connect(Socket.java:579)
   
10.         at java.net.Socket.connect(Socket.java:528)
    
11.         at java.net.Socket.<init>(Socket.java:425)
    
12.         at java.net.Socket.<init>(Socket.java:208)
    
13.         at cn.study.inet.TransTextDemo.main(TransTextDemo.java:35)

复制代码

服务器端客户端颠倒一下

王陶成 发表于 2012-8-23 23:03
服务器端客户端颠倒一下

Socket s = new Socket("127.0.0.1",10006);
ServerSocket ss = new ServerSocket(10006);
这两句换一下位置怎么就可以了呢?这是什么原理

new Thread(new TransServer(ss)).start();
new Thread(new TransClient(s)).start();
换这两句怎么不行?

先建立服务器端确定监听的端口再建立客户端，这样客户端才能访问到服务器端。否则会抛出拒绝访问。你说的交换后面启动线程的那两句是不行的。

周开伟 发表于 2012-8-24 02:19
先建立服务器端确定监听的端口再建立客户端，这样客户端才能访问到服务器端。否则会抛出拒绝访问。你说的交 ...

嗯,现在想明白了,之前一直想不明白,总以为是线程先后执行的问题