java - 将子类对象分配给父类对象

标签 java sockets networking parent-child subclass

我正在实现一个我一直在开发的网络库,但我在使用其中一个服务器系统时遇到了困难。

在库中,我有一个名为 ConnectedClient 的类,它是在远程客户端连接到服务器时创建的。换句话说,当服务器收到连接时,它会创建一个 ConnectedClient 对象,并将该对象传递给重写的方法。

以下是相关的服务器代码:

public void run() {
        if (IsConnectionActive()) {
            System.err.println("Cannot initialize server. Server is already running: " + serverSocket);
            return;
        }

        System.out.println("Initializing multiclient server...");
        try {
            Init();
            System.out.println("Server Initialized.");
            threadActive = true;
        } catch (ServerInitializeException e) {
            System.err.println(e.getMessage());
            return;
        }

        System.out.println("Waiting for client connections...");

        while (threadActive) {
            try {
                Socket s = serverSocket.accept();
                ConnectedClient temp = new ConnectedClient(s);
                connectedClients.add(temp);
                System.out.println("Client connection caught and initialized. Client: " + s);
                System.out.println("Connection with " + s + " now listening for incoming packets.");
                ThreadAction(temp);
                CleanClientList();
            } catch (SocketTimeoutException e) {
            } catch (IOException e) {
                System.err.println("Error accepting a client. Connection refused and reset.");
            } catch (ConnectionInitializationException e) {
                System.err.println(e.getMessage() + " Connection refused and reset.");
            }
        }
    }

    protected void ThreadAction(ConnectedClient client) {

    }

方法ThreadAction被最终用户客户端覆盖,这就是接受新连接的方式。

这是 ConnectedClient 代码:

public class ConnectedClient extends Connection implements Runnable {

    public ConnectedClient(Socket socket) throws ConnectionInitializationException {
        connectedSocket = socket;
        OpenIOStreams();
    }

    @Override
    public void run() {
        while (IsConnectionActive()) {
            try {
                ThreadAction(ReceivePacket());
            } catch (ReadPacketException e) {
                System.err.println(e.getMessage() + " Closing connection.");
                try {
                    CloseIOStreams();
                } catch (ConnectionException e1) {
                    System.err.println(e.getMessage());
                }
            }
        }
    }

    public void ThreadAction(Packet p) {
        if (p.packetType == Packet.PACKET_TYPE.Message)
            System.out.println(p.packetString);
        else if (p.packetType == Packet.PACKET_TYPE.CloseConnection) {
            System.out.println("Client wishes to close connection. Closing.");
            try {
                CloseIOStreams();
            } catch (ConnectionException e) {
                System.err.println(e.getMessage());
            }
        } else {
        }
    }
}

*它扩展的类Connection只是一个包含多个变量的蓝图

在实现中,我重写了服务器方法,如下所示:

public Server(int port) {
        super(port);
        clients = new ArrayList<ClientConnection>();
        clientThreads = new ArrayList<Thread>();
    }

    @Override
    public void ThreadAction(ConnectedClient cc) {
        // ClientConnection temp = (ClientConnection) cc;
        // clients.add(temp);



        Thread t = new Thread(cc);
        clientThreads.add(t);
        t.start();
    }

这一切都有效,我可以访问服务器内的 ConnectedClient 对象,发送和接收默认消息等。但是,当我尝试修改我的 时,问题就出现了ConnectedClient ThreadAction(Packet) 方法。首先,我尝试创建 ConnectedClient 类的扩展,如下:

public class ClientConnection extends ConnectedClient {

    public ClientConnection(Socket socket) throws ConnectionInitializationException {
        super(socket);
    }

    @Override
    public void ThreadAction(Packet p) {

    }

}

但是,当我尝试将新对象分配给服务器 ThreadAction(Packet) 方法中传递的对象时(如该方法中的注释所示),抛出了一个异常,表示我无法将 ConnectedClient 转换为 ClientConnection

那么,如何重写我的 ConnectedClient ThreadAction(Packet) 方法,并将其与服务器中传递的对象一起使用?例如,如果我希望我的 ConnectedClient ThreadAction(Packet) 每当客户端向服务器发送数据包时打印出“收到的数据包”,而不是数据包的消息,我如何重写该方法这样做,而不改变库?

抱歉,如果我不清楚,或者没有提供足够的信息,我有点慌张,因为我已经在这个问题上工作了几天,而且它已经让我变得更好了。如果需要,我可以提供更多信息。

感谢您的帮助!

最佳答案

However, when I tried to assign a new object to the passed object in my server ThreadAction(Packet) method (as shown in my comments within that method), an exception was thrown saying that I cannot cast ConnectedClient to ClientConnection.

无法ConnectedClient强制转换为ClientConnectionClientConnectionConnectedClient 的子类,因此无法进行强制转换 - 如果您要强制转换为父对象,则只能将一个对象强制转换为另一个对象。也就是说,您只能将 ClientConnection 转换为 ConnectedClient

想想类java.lang.Stringjava.lang.Object。您可以将 String 转换为 Object,因为 String 是 object 的子类,因此是一个 Object,您无法将 Object 转换为 String,因为无法验证 Object 是否确实是 String。这就是您无法转换对象的原因。

<小时/>

您要做的是创建一个可以转换两者的方法。此方法应接收 ConnectedClient,并返回 ClientConnection

public static ClientConnection conntectedClientToClientConnection(ConnectedClient client){
    //Make a ClientConnection that represents the ConnectionClient object
    //Return it
}

您还可以在 ClientConnection 中创建一个接受 ConnectionClient 的构造函数。

在方法/构造函数内,您需要“复制变量”。也就是说,确保 ClientConnection 对象内的所有变量与 ConnectionClient 对象内的变量相同。

<小时/>

您可以尝试的另一件事是更改服务器代码类中的代码。

更改此:

Socket s = serverSocket.accept();
ConnectedClient temp = new ConnectedClient(s);
connectedClients.add(temp);
System.out.println("Client connection caught and initialized. Client: " + s);
System.out.println("Connection with " + s + " now listening for incoming packets.");
ThreadAction(temp);
CleanClientList();

对此:

Socket s = serverSocket.accept();
ClientConnection temp = new ClientConnection(s); //Changed this line
connectedClients.add(temp);
System.out.println("Client connection caught and initialized. Client: " + s);
System.out.println("Connection with " + s + " now listening for incoming packets.");
ThreadAction(temp);
CleanClientList();

这将执行您所要求的操作,前提是 ClientConnection 类也有一个接受套接字的构造函数。

关于java - 将子类对象分配给父类对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37633536/

相关文章:

java - Postgres spring boot R2dbc应用程序中缺少DatabaseClient

macos - 如何让 DNS 解析在 El Capitan 上的 Mac OS X `chroot` 内工作?

windows - IE 无法访问 localhost,但 chrome 和 firefox 可以

c# - Unity 5联网色彩同步

c# - 应用程序中包含的 VPN 连接

java - Gson:日期上的 JsonSyntaxException

Javascript 和 JSP 未重新加载

java - 多维数组和方法

linux - 我可以通过远程安装 .X11-unix 来与 X 服务器通信吗?

sockets - 为什么使用 UDP 套接字时不需要调用 listen() 函数?