代码之家  ›  专栏  ›  技术社区  ›  Hunter Mitchell

Java套接字侦听器问题?

  •  1
  • Hunter Mitchell  · 技术社区  · 11 年前

    我已经被这个问题困扰了一段时间。我正在尝试用PHP将数据发送到Java服务器。当我在Bukkit中加载插件时,当我调用此函数时,它会停止加载:

    public void SocketListen()
    {       
    
        String clientSentence;
        String capitalizedSentence;
    
        try
        {
    
            ServerSocket welcomeSocket = new ServerSocket(25566);
    
            while(true)
            {
               Socket connectionSocket = welcomeSocket.accept();
               BufferedReader inFromClient =
                  new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
               DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());
               clientSentence = inFromClient.readLine();
               System.out.println("Received: " + clientSentence);
               capitalizedSentence = clientSentence.toUpperCase() + '\n';
               outToClient.writeBytes(capitalizedSentence);
            }
        }
        catch(IOException e)
        {
            getLogger().severe(e.toString());
        }
    
    }
    

    这告诉我做错了什么。我的PHP是:

    <?php
    $host = "localhost"; 
    $port = 25566;
    $data = 'test\n';
    
    if ( ($socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === FALSE )
        echo "socket_create() failed: reason: " . socket_strerror(socket_last_error());
    else 
    {
        echo "Attempting to connect to '$host' on port '$port'...<br>";
        if ( ($result = socket_connect($socket, $host, $port)) === FALSE )
            echo "socket_connect() failed. Reason: ($result) " . socket_strerror(socket_last_error($socket));
        else {
            echo "Sending data...<br>";
            socket_write($socket, $data, strlen($data));
            echo "OK<br>";
    
            echo "Reading response:<br>";
            while ($out = socket_read($socket, 2048)) {
                echo $out;
            }
        }
        socket_close($socket);      
    }
    ?>
    

    我做错了什么?

    基本上,我只需要PHP服务器发送“Hello”,然后Java客户端用getLogger().info(data)发出它;

    此外,我需要在客户端或服务器上用PHP转发25566吗?它们都托管在我的本地网络上,具有相同的外部IP。

    1 回复  |  直到 11 年前
        1
  •  0
  •   Ashley    11 年前

    这可能是因为循环从未停止:

     while(true)
        {
          //code
    

    您可以使用我为java服务器和客户端创建的类:

    查特克莱恩

        package com.weebly.foxgenesis.src;
    import java.net.*;
    import java.io.*;
    
    public final class ChatClient
    {  
        private Socket socket = null;
        private DataOutputStream streamOut = null;
        private ChatClientThread client = null;
        private String serverName = "localhost";
        private int serverPort = -1;
        private final ChatReciever output;
    
    /**
     * Create a new ChatClient that connects to a given server and receives UTF-8 encoded messages
     * @param a Client class
     */
    public ChatClient(ChatReciever chatReciever)
    { 
        output = chatReciever;
        serverPort = chatReciever.getPort();
        serverName = chatReciever.getHost();
        connect(serverName, serverPort);
    }
    
    private void connect(String serverName, int serverPort)
    {  
        output.handleLog("Establishing connection. Please wait ...");
        try
        {  
            socket = new Socket(serverName, serverPort);
            output.handle("Connected to chat server");
            open();
        }
        catch(UnknownHostException uhe)
        {  
            output.handleError("Host unknown: " + uhe.getMessage()); 
        }
        catch(IOException ioe)
        {  
            output.handleError("Unexpected exception: " + ioe.getMessage()); 
        } 
    }
    
    /**
     * Sends a message to the server through bytes in UTF-8 encoding 
     * @param msg message to send to the server
     */
    public void send(String msg) throws IOException
    {  
        streamOut.writeUTF(msg); 
        streamOut.flush();
    }
    
    /**
     * forces the ChatReciever to listen to a message (NOTE: this does not send anything to the server)
     * @param msg message to send
     */
    public void handle(String msg)
    {  
        output.handle(msg);
    }
    
    private void open() throws IOException
    {   
        streamOut = new DataOutputStream(socket.getOutputStream());
        client = new ChatClientThread(this, socket); 
    }
    
    /**
     * tries to close 
     */
    public void close() throws IOException
    {  
        if (streamOut != null)  
            streamOut.close();
        if (socket    != null)  
            socket.close(); 
    }
    
    /**
     * closes the client connection
     */
    @SuppressWarnings("deprecation")
    public void stop()
    {
        if(client != null)
            client.stop();
        client = null;
    }
    
    /**
     * checks if the ChatClient is currently connected to the server
     * @return Boolean is connected
     */
    public boolean isConnected()
    {
        return client == null ?(false) : (true);
    }
    }
    

    聊天服务器线程

       package com.weebly.foxgenesis.src;
    
    
    
    import java.net.*;
    import java.io.*;
    
    public final class ChatClientThread extends Thread
    {  
        private Socket           socket   = null;
        private ChatClient       client   = null;
        private DataInputStream  streamIn = null;
    
        public ChatClientThread(ChatClient _client, Socket _socket)
        {  
            client   = _client;
            socket   = _socket;
            open();  
            start();
        }
        public void open()
        {  
            try
            {  
                streamIn  = new DataInputStream(socket.getInputStream());
            }
            catch(IOException ioe)
            {  
                System.out.println("Error getting input stream: " + ioe);
                client.stop();
            }
        }
        public void close()
        {  
            try
            {  
                if (streamIn != null) streamIn.close();
            }
            catch(IOException ioe)
            {  
                System.out.println("Error closing input stream: " + ioe);
            }
        }
        public void run()
        {  
            while (true)
            {  
                try
                {  
                    client.handle(streamIn.readUTF());
                }
                catch(IOException ioe)
                { 
                    System.out.println("Listening error: " + ioe.getMessage());
                    client.stop();
                }
            }
        }
    }
    

    聊天接收者

     package com.weebly.foxgenesis.src;
    
    public interface ChatReciever 
    {
        /**
         * gets the IP address of the host
         * @return String IP address
         */
        public String getHost();
    
        /**
         * gets the port of the host
         * @return Integer port of host
         */
        public int getPort();
    
        /**
         * sends a message from the server to the implementing class
         * @param msg message from the server
         */
        public void handle(String msg);
    
        /**
         * sends an error to the implementing class
         * @param errorMsg error message
         */
        public void handleError(String errorMsg);
    
        /**
         * Sends a message to the log
         * @param msg message to send
         */
        public void handleLog(Object msg);
    }