我正在实现一个我一直在开发的网络库,但我在使用其中一个服务器系统时遇到了困难。
在库中,我有一个名为 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
强制转换为ClientConnection
。 ClientConnection
是 ConnectedClient
的子类,因此无法进行强制转换 - 如果您要强制转换为父对象,则只能将一个对象强制转换为另一个对象。也就是说,您只能将 ClientConnection
转换为 ConnectedClient
。
想想类java.lang.String
和java.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/