A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

我刚写了一个基于TCP的聊天小程序,客户端运行时有如下报错:
Exception in thread "main" java.net.ConnectException: Connection timed out: conn
ect
        at java.net.DualStackPlainSocketImpl.connect0(Native Method)
        at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketI
mpl.java:79)
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.ja
va:339)
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocket
Impl.java:200)
        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java
:182)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:579)
        at java.net.Socket.connect(Socket.java:528)
        at java.net.Socket.<init>(Socket.java:425)
        at java.net.Socket.<init>(Socket.java:208)
        at ClientB.main(TCPChat.java:5)
源代码如下:
import java.io.*;
import java.net.*;
class ClientB {
   public static void main(String[] args) throws Exception {
      Socket s = new Socket( "202.199.2.134" , 8080);
      BufferedReader buf = new BufferedReader(new InputStreamReader(System.in ));
      BufferedWriter bufout= new BufferedWriter( new OutputStreamWriter(s.getOutputStream()));
      BufferedReader bufIn = new BufferedReader( new InputStreamReader(s.getInputStream()));
      String line = null ;
      while ((line = buf.readLine()) != null ) {
         if ( "over" .equals(line))
            break ;
            bufout.write(line);
            bufout.newLine();
            bufout.flush();
            String str=bufIn.readLine();
           System.out.print( "server:" +str);
      }
              s.close();
   }
}
class ServerA {
        public static void main(String []agrs) throws Exception        {
                ServerSocket ss= new ServerSocket(8080);
                Socket s= ss.accept();
                String ip=s.getInetAddress().getHostAddress();
                System.out.println(ip+ "我们连接成功了!" );
                BufferedReader buf = new BufferedReader( new InputStreamReader(s.getInputStream()));
                BufferedWriter bufout= new BufferedWriter( new OutputStreamWriter(s.getOutputStream()));
                String line= null ;
                while ((line=buf.readLine())!= null ){
                        System.out.println(line);
                        StringBuffer re= new StringBuffer(line);
                        String str=re.reverse().toString();
                        System.out.println(re+ "++   ++" +str);
                        bufout.write(str);
                        bufout.newLine();
                        bufout.flush();
                }
        s.close();
        }
  1. import java.io.*;
  2. import java.net.*;
  3. class ClientB {
  4.    public static void main(String[] args) throws Exception {
  5.       Socket s = new Socket( "202.199.2.134" , 8080);
  6.       BufferedReader buf = new BufferedReader(new InputStreamReader(System.in ));
  7.       BufferedWriter bufout= new BufferedWriter( new OutputStreamWriter(s.getOutputStream()));
  8.       BufferedReader bufIn = new BufferedReader( new InputStreamReader(s.getInputStream()));
  9.       String line = null ;
  10.       while ((line = buf.readLine()) != null ) {
  11.          if ( "over" .equals(line))
  12.             break ;
  13.             bufout.write(line);
  14.             bufout.newLine();
  15.             bufout.flush();
  16.             String str=bufIn.readLine();
  17.            System.out.print( "server:" +str);
  18.       }
  19.               s.close();
  20.    }
  21. }
  22. class ServerA {
  23.         public static void main(String []agrs) throws Exception        {
  24.                 ServerSocket ss= new ServerSocket(8080);
  25.                 Socket s= ss.accept();
  26.                 String ip=s.getInetAddress().getHostAddress();
  27.                 System.out.println(ip+ "我们连接成功了!" );
  28.                 BufferedReader buf = new BufferedReader( new InputStreamReader(s.getInputStream()));
  29.                 BufferedWriter bufout= new BufferedWriter( new OutputStreamWriter(s.getOutputStream()));
  30.                 String line= null ;
  31.                 while ((line=buf.readLine())!= null ){
  32.                         System.out.println(line);
  33.                         StringBuffer re= new StringBuffer(line);
  34.                         String str=re.reverse().toString();
  35.                         System.out.println(re+ "++   ++" +str);
  36.                         bufout.write(str);
  37.                         bufout.newLine();
  38.                         bufout.flush();
  39.                 }
  40.         s.close();
  41.         }
  42. }
复制代码

}
客户端和服务器端不能进行正常通信,是不是输入流的问题?求指点。

4 个回复

倒序浏览
聊天程序是面向非连接的,要使用UDP。TCP是面向连接的,你不可能和服务器聊天啊。
回复 使用道具 举报
服务器,是不能主动向客户端发送信息的。
回复 使用道具 举报
代码没有问题啊,8080端口是www服务器在使用的端口,你改成其他端口,别低于1000(系统软件使用)就好。
还有IP地址可能会变,建议使用InetAddress.getLocalHost()方法获取本地地址。
回复 使用道具 举报
应该用UDP吧
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马