当前位置:  开发笔记 > 编程语言 > 正文

ServerSocket无法从客户端读取输入

如何解决《ServerSocket无法从客户端读取输入》经验,为你挑选了1个好方法。

我是套接字编程的新手,我只是在尝试一些东西。我正在尝试做的是让一个客户端读取一个文本文件,将该文件中的行保存在ArrayList中,然后将这些行发送到服务器。这是我的代码。连接已成功建立,但是当服务器尝试从其BufferedReader读取时,它什么也没得到:

服务器:

import java.io.*;
import java.net.*;

    public class Server extends Thread{
        ServerSocket sock = null;
        Socket client_sock = null;
        PrintWriter out = null;
        BufferedReader in = null;


        Server(int port){
            try{
            sock = new ServerSocket(port);
        }catch(IOException e){
            System.out.println("Couldn't create server socket");
            e.printStackTrace();
        }
        }

        public void run(){
            while (true){
                try{
                    client_sock = sock.accept();
                    System.out.println("Successfully connected to client" + client_sock);
                    System.out.println(client_sock.getOutputStream());
                    System.out.println(client_sock.getInputStream());
                    out = new PrintWriter(client_sock.getOutputStream(),true);
                    //System.out.println(out);
                    in = new BufferedReader(new InputStreamReader(client_sock.getInputStream()));
                    //System.out.println(in);
                    System.out.println("Trying to read line sent from client:");
                    String l;
                    try{    
                        l = in.readLine();
                        System.out.println(l);
                    }catch(IOException e){
                        System.out.println("Couldn't read line from client");
                        e.printStackTrace();}

                }catch(IOException e){
                    e.printStackTrace();
                    break;
                }
            }



        }

        public static void main(String[] args){
            //Thread t = new Server(Integer.parseInt(args[0]));
            //t.start();
            Server serv = new Server(10239);
            System.out.println(serv.sock);
            serv.run();

        }


    }

客户:

import java.net.*;
import java.io.*;
import java.util.*;

public class Client {
    Socket sock = null;
    OutputStream toServer = null;
    PrintWriter out = null;
    InputStream fromServer = null;
    BufferedInputStream in = null;
    Client(int port){
        try{
            sock = new Socket("localhost",port);
            //System.out.println(sock.getPort());
            //System.out.println(sock.getOutputStream());
            //System.out.println(sock.getInputStream());
            //toServer = sock.getOutputStream();
            //System.out.println(sock.getOutputStream());
            out = new PrintWriter(sock.getOutputStream());
            //System.out.println(out);
            //fromServer = sock.getInputStream();
            in = new BufferedInputStream(sock.getInputStream());
            //System.out.print(in);
        }catch(UnknownHostException ue){
            System.out.println("Host not known");
        }
        catch(IOException e){
            e.printStackTrace();
        }
    }

    public static void main(String[] args){
        Client client = new Client(Integer.parseInt(args[0]));
        File f = new File("/Users/--------/Desktop/socket_test.txt");
        BufferedReader f_in = null;
        try{    
            f_in = new BufferedReader(new FileReader(f));
        }catch(IOException e){
            System.out.println("Cannot create FileReader for test file");
        }

        String line;
        ArrayList text = new ArrayList();
        try{
            while ((line = f_in.readLine()) != null){
                text.add(line);
            }
        }catch(IOException e){
            e.printStackTrace();
        }

        //System.out.println("first line of file");
        //System.out.println(text.get(0));


        for (String l : text){
            System.out.println("Sent the following line:");
            System.out.println(l);
            client.out.println(l);
        }

    }
}   

这是我为客户端获得的输出:

Sent the following line:
Similar to the previous constructor 
Sent the following line:
the InetAddress parameter specifies 
Sent the following line:
the local IP address to bind to. 
Sent the following line:
The InetAddress is used for servers that 
Sent the following line:
may have multiple IP addresses
Sent the following line:
allowing the server to specify which of 
Sent the following line:
its IP addresses to accept client requests on

对于服务器:

ServerSocket[addr=0.0.0.0/0.0.0.0,localport=10239]
Successfully connected to clientSocket[addr=/127.0.0.1,port=58285,localport=10239]
Trying to read line sent from client:
null

我找不到这种方法不起作用的原因,有人可以帮我吗?



1> Arnaud..:

尝试在每一行之后刷新流:

client.out.println(l);
client.out.flush();

推荐阅读
coco2冰冰
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有