0

私はJavaソケットプログラムに取り組んでおり、クライアント部分に問題があります。サーバーはすべてのクライアントが書き込んだものを取得しますが、クライアントは自分が書き込んだものしか取得しません。すべてのクライアントが書いたものを取得するプログラムのクライアント部分の例を教えてもらえますか? ありがとう!

4

1 に答える 1

1

これは「エコーサーバー」の例です

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

class TCPServer
{
public static void main(String argv[]) throws IOException
{
    ServerSocket serverSocket = null;
    DataInputStream serverInput = null;
    PrintStream serverOutput = null;
    String line = null;
    Socket clientSocket = null;

    // create server socket
    try
    {
        serverSocket = new ServerSocket(2012);
        clientSocket = serverSocket.accept();
        serverInput = new DataInputStream(clientSocket.getInputStream());
        serverOutput = new PrintStream(clientSocket.getOutputStream());
    }
    catch(IOException e){System.out.println(e);}


    // receive data and send it back to the client
    try
    {
        while(true)
        {
            line = serverInput.readLine();
            if(line.equals("exit"))
            {
                break;
            }
            else
            {
                if(!line.equals(null) && !line.equals("exit"))
                {
                    System.out.println("Received " +line);
                    line = line+" MODIFIED";
                    serverOutput.println(line);
                }
            }
        }
    }
    catch(IOException e){System.out.println("SERVER SIDE: Unable send/receive data");}

    try
    {
        serverInput.close();
        serverOutput.close();
        clientSocket.close();
        serverSocket.close();
    }
    catch(IOException e){System.out.println(e);}
}
}

これがクライアントです

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

public class TCPClient
{
public static void main(String[] args) throws IOException 
{

    Socket echoSocket = null;
    PrintWriter out = null;
    BufferedReader in = null;

    try {
        echoSocket = new Socket("localhost", 2012);
        out = new PrintWriter(echoSocket.getOutputStream(), true);
        in = new BufferedReader(new InputStreamReader(echoSocket.getInputStream()));
    } catch (UnknownHostException e) {
        System.err.println("Don't know about host");
        System.exit(1);
    } catch (IOException e) {
        System.err.println("Couldn't get I/O");
        System.exit(1);
    }

BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
String userInput;

while ((userInput = stdIn.readLine()) != null) {
    out.println(userInput);
    System.out.println("echo: " + in.readLine());
    if(userInput.equals("exit"))
    break;
}

out.close();
in.close();
stdIn.close();
echoSocket.close();
}
}
于 2013-01-08T17:53:36.613 に答える