黑马程序员技术交流社区

标题: Tcp网络编程遇到的问题 [打印本页]
作者: hhmm665544    时间: 2014-4-9 17:04
标题: Tcp网络编程遇到的问题
  1. import java.net.*;
  2. import java.io.*;
  3. public class TCPDemo
  4. {

  6.         public static void main(String[] args) throws Exception
  7.         {
  8.                 // TODO 自动生成的方法存根
  9.                
  10.                 Socket s = new Socket("192.168.1.103",11908);//这句代码有什么问题吗?
  11.                 ServerSocket ss = new ServerSocket(11908);
  12.                
  13.                 new Thread(new TCPServerDemo(ss)).start();
  14.                 new Thread(new TCPClientDemo(s)).start();
  15.         }

  17. }
  18. class TCPClientDemo implements Runnable
  19. {
  20.         private Socket s;
  21.         public TCPClientDemo(Socket s)
  22.         {
  23.                 this.s = s;
  24.         }
  25.         public void run()
  26.         {
  27.                 try{
  28.                         Thread.sleep(2000);
  29.                         OutputStream out = s.getOutputStream();
  30.                         out.write("TCP ge men lai le ".getBytes());
  31.                         s.close();
  32.                 }
  33.                 catch(Exception e)
  34.                 {
  35.                         throw new RuntimeException("客户端异常");
  36.                 }
  37.         }
  38. }

  40. class TCPServerDemo implements Runnable
  41. {
  42.         private ServerSocket ss;
  43.         public TCPServerDemo(ServerSocket ss)
  44.         {
  45.                 this.ss = ss;
  46.         }
  47.         public void run()
  48.         {
  49.                 // TODO 自动生成的方法存根
  50.                 try{
  51.                                 Socket s = ss.accept();
  52.                                 InputStream in = s.getInputStream();
  53.                                 byte[] buf = new byte[1024];
  54.                                 int len = in.read(buf);
  55.                                 String ip = s.getInetAddress().getHostAddress();
  56.                                 System.out.println(ip+new String(buf,0,len));
  57.                                 s.close();
  58.                                 ss.close();
  59.                 }
  60.                 catch(Exception e)
  61.                 {
  62.                         throw new RuntimeException("服务端异常");
  63.                 }
  64.         }

  66. }
复制代码


Exception in thread "main" java.net.ConnectException: Connection refused: connect
        at java.net.DualStackPlainSocketImpl.connect0(Native Method)
        at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
        at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
        at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
        at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
        at java.net.PlainSocketImpl.connect(Unknown Source)
        at java.net.SocksSocketImpl.connect(Unknown Source)
        at java.net.Socket.connect(Unknown Source)
        at java.net.Socket.connect(Unknown Source)
        at java.net.Socket.<init>(Unknown Source)
        at java.net.Socket.<init>(Unknown Source)
        at TCPDemo.main(TCPDemo.java:10)


求高手给解答下啊
作者: caijunsong    时间: 2014-4-10 00:16
我猜你是不是把这一大段的代码 给直接放在一个java中去编译运行了？？？
你代码一看就知道到错在哪！！
你是把服务端和客服端 用两个线程重写，你希望它切换运行？
你的异常的意思是 你发出请求给服务端 但是服务端并没有启动 当然会连接不上啦
你创建两个线程 线程之间谁先运行取决于系统的调度  要是服务端的那个线程刚好比客服端的先运行 兴许还能运行成功   要是客服端的的线程比服务端先运行的话 不就是请求连接失败

正确的做法是   分别用两个文件各自启动服务端  和 客服端 且 服务端要先运行与客服端
你试试！
我没有写代码 给你演示  希望版主给分
作者: NO?    时间: 2014-4-10 00:29
问题在于你先有客户端，客户端一存在就会去链接服务端。
但你的客户端存在时，你的服务端还没有产生呢
正确的做法应该是吧第十行和第十一行的代码互换一下。
就可以解决。当然，你还得确定你所用的端口号没有被系统占用。
作者: Kelvinhu    时间: 2014-4-10 01:38
本帖最后由 Kelvinhu 于 2014-4-10 01:41 编辑
  1. //服务端：
  2. import java.io.*;
  3. import java.net.*;


  6. public class Chat {
  7.         public static void main(String[] args) {
  8.                 ServerSocket server = null;
  9.                
  10.                 try {
  11.                         server = new ServerSocket(6665);
  12.                 } catch (IOException e) {
  13.                         System.out.println("端口被占用，创建端口失败。");
  14.                 }
  15.                 Socket socket = null;
  16.                 while (true){
  17.                         try {
  18.                                 socket = server.accept();
  19.                         } catch (IOException e) {
  20.                                 System.out.println("客户端连接失败。");
  21.                         }
  22.                         new Thread(new Rev(socket)).start();
  23.                 }
  24.         }
  25. }

  27. class Rev implements Runnable{
  28.         Socket socket = null;
  29.         
  30.         Rev(Socket socket){
  31.                 this.socket = socket;
  32.         }
  33.         
  34.         public void run(){
  35.                 String ip=socket.getInetAddress().toString();
  36.                 try {
  37.                         while(true){
  38.                         DataInputStream ds = new DataInputStream(socket.getInputStream());
  39.                         String message = ds.readUTF();
  40.                         System.out.println(ip+"：   "+message);
  41.                         }
  42.                 } catch (IOException e) {
  43.                         System.out.println("客户端"+ip+"已退出！");
  44.                 }
  45.         }        
  46. }
复制代码
  1. //客户端：

  3. import java.net.*;
  4. import java.io.*;
  5. import java.util.*;

  7. class Client{
  8.         public static void main(String args[]) throws Exception{
  9.                 Socket s = new Socket("127.0.0.1",6665);
  10.                
  11.                 OutputStream os = s.getOutputStream();
  12.                 DataOutputStream dos = new DataOutputStream(os);
  13.                 while(true){
  14.                         Scanner scanner = new Scanner(System.in);
  15.                         String string=scanner.next();
  16.                         if (string.equals("exit")){
  17.                                 System.out.println("退出了~");
  18.                                 s.shutdownInput();
  19.                                 dos.close();
  20.                                 s.close();
  21.                                 System.exit(0);
  22.                         }
  23.                         dos.writeUTF(string);
  24.                         dos.flush();
  25.                 }
  26.         }
  27. }
复制代码

看了下LZ出的错误是Exception in thread "main" java.net.ConnectException: Connection refused: connect
意思是不能连接出的错，要先启动服务端，再启动客户端才可以~






欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2