1

我设法编写了一个简单的程序，该程序应该模拟由三个组件组成的系统中的传递控制。但我不确定我是否做得正确，因为日志看起来不像我预期的那样。

我找不到错误。是在 aspectJ 部分还是在 RMI 部分？

RMI服务器

public class RMIServer {

    public static void main(String[] args) throws RemoteException,
            MalformedURLException {
        LocateRegistry.createRegistry(1099);
        HelloIF hello = new Hello();
        Naming.rebind("server.Hello", hello);
        System.out.println("Server is ready.");
    }
}

RMI服务器2

public class RMIServer2 {

    public static void main(String[] args) throws RemoteException,
            MalformedURLException, NotBoundException, InterruptedException {

            //LocateRegistry.createRegistry(1098);
            LocateRegistry.getRegistry(1099);
        ByeIF bye = new Bye();
        Naming.rebind("server.Bye", bye);
        System.out.println("Server-Client is ready.");

    }

RMI客户端

public class RMIClient {
        public static void main(String[] args) throws RemoteException,
                MalformedURLException, NotBoundException, InterruptedException {

            Registry registry = LocateRegistry.getRegistry("localhost");
            ByeIF bye = (ByeIF) registry.lookup("server.Bye");
            System.out.println(bye.farewell(Thread.currentThread().getName()));
        }
}

你好

public class Hello extends UnicastRemoteObject implements HelloIF {

    public Hello() throws RemoteException {
    }

    public String greeting(String c) throws RemoteException,
            InterruptedException {
        return "Good morning!";
    }
}

再见

public class Bye extends UnicastRemoteObject implements ByeIF {

    public Bye() throws RemoteException {
    }

    public String farewell(String c) throws RemoteException,
            InterruptedException, NotBoundException {
        Registry registry = LocateRegistry.getRegistry("localhost");
        HelloIF hello = (HelloIF) registry.lookup("server.Hello");
        System.out.println(hello.greeting(Thread.currentThread().getName()));
        return "Bye bye!";
    }

}

日志看起来：

[2012-08-03 11:06:18,582] [request1343984778582] [public static void hello.RMIClient.main(java.lang.String[])]
[2012-08-03 11:06:18,738] [request1343984778582] [public java.lang.String hello.Bye.farewell(java.lang.String)]
[2012-08-03 11:06:18,785] [request1343984778582] [public java.lang.String hello.Hello.greeting(java.lang.String)]
[2012-08-03 11:06:18,785] [request1343984778582] [public java.lang.String hello.Hello.greeting(java.lang.String)]
[2012-08-03 11:06:18,847] [request1343984778582] [public static void hello.RMIClient.main(java.lang.String[])]

所以缺少一个日志 -Bye.farewell()

我不知道为什么 aspectJ 看不到方法何时结束。

@Aspect
public class ReportingAspect {

    // --------------------------------------LOGGER

    static final Logger logger = Logger.getLogger(ReportingAspect.class);

    // --------------------------------------POINTCUTS

    @Pointcut("execution(public static void hello.RMIClient.main(String[]))")
    public void requestStart() {
    }

    @Pointcut("(execution(String greeting(..)) && args(context)) || "
            + "(execution(String farewell(..)) && args(context))")
    public void RMImethodStart(String context) {
    }

    @Pointcut("execution(String greeting(..)) || "
            + "execution(String farewall(..)) || "
            + "execution(public static void hello.RMIClient.main(String[]))")
    public void general() {
    }

    @Pointcut("execution(public static void hello.RMIServer.main(String[])) || "
            + "execution(public static void hello.RMIServer2.main(String[]))")
    public void setLoggingFile() {
    }

    // --------------------------------------ADVICES

    @Before("requestStart()")
    public void setLoggerAndThreadName(JoinPoint joinPoint) {
        PropertyConfigurator.configure("log4j.properties");
        Thread.currentThread().setName("request" + System.currentTimeMillis());
        report(joinPoint);
    }

    @Before("RMImethodStart(context)")
    public void setThreadName(JoinPoint joinPoint, String context) {
        Thread.currentThread().setName(context);
        report(joinPoint);
    }

    @Before("setLoggingFile()")
    public void setProperties() {
        PropertyConfigurator.configure("log4j.properties");
    }

    @After("general()")
    public void generateReport(JoinPoint joinPoint) {
        report(joinPoint);
    }

    /*//!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
    @After("execution(public String hello.Bye.farewell(String))")
    public void test(JoinPoint joinPoint)
    {
        report(joinPoint);
    }*/

    // ---------------------------------------REPORT
    void report(JoinPoint jp) {
        logger.error(jp.getSignature().toLongString());
    }
}
4

1 回答 1

1

如果你发现一个你不理解的错误，试着减少问题。在您的情况下，在实际代码中使用一些旧System.out.println()代码如何查看真正发生的情况？

另外，我没有看到任何异常处理。根据您的 Java 版本，main()可能会吞下异常。

于 2012-08-02T12:14:29.773 回答