我正在尝试使用Java RMI构建分布式应用程序,并且我在这些领域做了很多实践和研究。这么多例子都很好用。这里的代码适用于服务器端,当我通过 cmd 运行应用程序时,它没有任何问题,但它在 2-4 秒后关闭,然后它就这样绑定服务,因此客户端给出"NOTBOUND 异常"。疯狂的部分是相同的代码在 Anthor 应用程序中运行得非常顺利。
这是我使用的所有代码
脸.java
package rmi;
import java.rmi.*;
public interface RInterface extends Remote {
public boolean log(String Uname, String code) throws RemoteException;
}
RClass.java
package rmi;
import java.rmi.*;
import java.rmi.server.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.swing.JOptionPane;
public class RClass extends UnicastRemoteObject implements RInterface {
private Connection connect = null;
private Statement statement = null;
private ResultSet resultSet = null;
private boolean stat = false;
public String state = "Waiting Confirmation ...";
public RClass() throws RemoteException {
super();
connect();
}
public boolean log(String Uname, String code) throws RemoteException {
try {
String sql = "select name,code from logusers where name='"+Uname+"' and code ='"+code+"'";
resultSet = statement.executeQuery(sql);
int count=0;
while (resultSet.next()) {
count+=1;
}
if (count==0) {
stat = false;
state = "NO User Found!! Access Denied";
}else
if (count>1) {
stat = false;
state = "duplicate User!! NOT allowed";
}else
if (count == 1){
stat = true;
state = "WelCome "+ Uname +"!! Access Granted";
}
} catch (SQLException e) {
JOptionPane.showMessageDialog(null,e);
}
return stat;
}
public final void connect(){
try{
Class.forName("com.mysql.jdbc.Driver");
connect = DriverManager.getConnection("jdbc:mysql://localhost/eysa?"+"user=root&password=");
statement = connect.createStatement();
} catch(ClassNotFoundException | SQLException e){
System.exit(0);
}
}
}
myServer.java(我的痛苦之源)
package rmi;
import java.net.MalformedURLException;
import java.rmi.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JOptionPane;
public class myServer {
myServer() {
new Thread(){
public void run(){
try{
RInterface stub = new RClass();
Naming.rebind("rmi://localhost/LOGIN",stub);
} catch(RemoteException e){
JOptionPane.showMessageDialog(null, e);
} catch (MalformedURLException ex) {
Logger.getLogger(myServer.class.getName()).log(Level.SEVERE, null, ex);
}
}
}.start();
}
public static void main(String[] args) throws InterruptedException {
myServer myS = new myServer();
JOptionPane.showMessageDialog(null, "Server is Ready...");
}
}
myClient.java是非常简单的代码,我认为没有必要附加它。
您正在退出 vi 在其他空的异常处理程序中的 System.exit()
调用。
不要这样写代码。捕获异常时,打印或记录异常,或者最好是堆栈跟踪。那么调试将不仅仅是一个猜谜游戏。
注意,一个 JDBC 连接和一个语句对于 RMI 服务器来说是不够的。RMI 是自动多线程的。每个远程方法调用都需要一个连接和语句。