0

好吧，我正在尝试设置一个程序，我必须从套接字接收数据，并将数据发送到套接字。我很难理解如何让套接字的客户端发送特定数据，然后让服务器端发送特定数据。这是我目前拥有的，它只是我的服务器端，因为到目前为止我真的迷失在客户端部分。

为了进一步评估，我想做如下所列，但我不知道要研究什么来编写套接字的客户端，如果有任何代码我需要在服务器端重写? 进一步评估

package sockets;
import java.net.*;
import java.io.*;

public class SocketMain {
    private int port = 0;
    public ServerSocket socket;
    public Socket clientSock;

    public SocketMain() {
        init();
    }

    public static void main(String[] args) {
        new SocketMain();
    }

    private void init() {
        try { 
            socket = new ServerSocket(port);
            System.out.println("Server started, bound to port: "+port);
            clientSock = socket.accept();
            File directory = new File("./Storage/");
            if (!directory.exists()) {
                directory.mkdirs();
            }
            File file = new File(directory + "/Store.dat");
            if (!file.exists()) {
                file.createNewFile();
            }
            DataInputStream in = new DataInputStream(clientSock.getInputStream());  
            FileWriter fw = new FileWriter(file);
            BufferedWriter bw = new BufferedWriter(fw);
            String line;
            while ((line = in.readLine()) != null) {
                System.out.println(line);
                bw.write(line+"\n");
                bw.flush();
                bw.close();
            }
            socket.close();
            clientSock.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }
}
4

2 回答 2

5

关于你目前拥有的：

首先映入我眼帘的是这个循环：

while ((line = in.readLine()) != null) {
    System.out.println(line);
    bw.write(line+"\n");
    bw.flush();
    bw.close(); // <- Problem
}

每次写一行时，您都会关闭作家。现在，作为Writer.close()国家的文件：

关闭流，首先刷新它。一旦流被关闭，进一步的 write() 或 flush() 调用将导致抛出 IOException。关闭以前关闭的流没有效果。

您应该IOException在第一行之后的每一行都得到 s 。但是，您的程序不会崩溃，因为您正在捕获异常。

其次，您使用DataInputStream从客户端读取，但使用BufferedWriter. 正如其文档中的前者所述：

数据输入流允许应用程序以与机器无关的方式从底层输入流中读取原始 Java 数据类型。应用程序使用数据输出流写入数据，这些数据稍后可以由数据输入流读取。

该类包括布尔、char、int 以及您能想到的任何原始数据类型的多种方法。但是对于DataInputStream.readLine()-method，它明确指出：

已弃用。此方法不能正确地将字节转换为字符。 从 JDK 1.1开始，读取文本行的首选方法是通过 BufferedReader.readLine()方法。

因此，对于读取字符串，您应该使用BufferedReader.

关于你还没有的：

套接字上的通信建立在“问-答”基础上。工作流程应该是这样的：

  1. 客户端打开连接
  2. 服务器接受连接
  3. 客户要求一些东西（使用 server-sockets OutputStream）
  4. 服务器读取请求（使用 client-sockets InputStream）
  5. 服务器回答（使用 client-sockets OutputStream）
  6. 客户端读取答案（使用 server-sockets InputStream）
  7. 如有必要，重复步骤 3-6。
  8. 连接已关闭（由客户端、服务器或两者）。
于 2012-10-22T22:05:36.983 回答
0

除了：

DataInputStream in = new DataInputStream(clientSock.getInputStream());  
while ((line = in.readLine()) != null) {

DataInputStream.getLine()已弃用-您应该只使用BufferedReader.getLine()：

使用 DataInputStream 类读取行的程序可以通过替换形式的代码转换为使用 BufferedReader 类：

DataInputStream d = new DataInputStream(in);

和：

BufferedReader d  = new BufferedReader(new InputStreamReader(in));
于 2012-10-22T21:46:35.497 回答