RMI Chủ đề ngăn JVM thoát ra sau khi main() hoàn thành

Question

Để tạo một câu chuyện dài ngắn, tôi gặp khó khăn khi nhận một vài chuỗi không phải daemon của RMI của Java để đóng sau khi ứng dụng của tôi không còn cần RMI nữa. Điều này ngăn không cho JVM thoát khi main() hoàn thành.

Tôi hiểu rằng việc xuất UnicastRemoteObject s sẽ khiến RMI rời khỏi chuỗi mở cho đến khi bạn gọi thành công UnicastRemoteObject.unexportObject(Object o,boolean force). Dưới đây là một ví dụ (chạy mà không sửa đổi và JVM sẽ thoát bình thường - loại bỏ các cuộc gọi đến unexportObject và JVM sẽ không bao giờ thoát):

import java.rmi.registry.LocateRegistry; 
import java.rmi.registry.Registry; 
import java.rmi.server.UnicastRemoteObject; 

public class TestUnicastRemoteObject{ 
private static UnicastRemoteObject obj; 
private static Registry registry; 

public static void main(String[] args) throws Exception{ 
    obj = new UnicastRemoteObject(){ 
     private static final long serialVersionUID = 1L; 
    }; 
    System.err.println("created UnicastRemoteObject"); 
    System.err.println("creating registry ..."); 
    registry = LocateRegistry.createRegistry(9999); 
    System.err.println("registry created."); 
    System.err.println("binding obj to registry ..."); 
    registry.bind("Test", obj); 
    System.err.println("bound"); 
    UnicastRemoteObject.unexportObject(obj, true); 
    System.err.println("unexported obj"); 
} 
} 

Ngoài ra, nó dường như không quan trọng cho dù bạn tạo registry và/hoặc gắn kết đối tượng từ xa với nó - điều duy nhất có vẻ quan trọng trong ví dụ này là bất cứ khi nào bạn tạo một UnicastRemoteObject, bạn cần gọi unexportObject để ngăn chặn bất kỳ luồng nào còn lại sau khi bạn hoàn thành. Trong ứng dụng của tôi, tôi đã chắc chắn rằng tôi đã gọi unexportObject trên mỗi UnicastRemoteObject tôi tạo ra, nhưng chuỗi RMI "reaper" và "connection accept" vẫn tồn tại, ngăn không cho JVM của tôi thoát khi ứng dụng của tôi kết thúc bằng tài nguyên RMI.

Có điều gì khác có thể khiến RMI rời khỏi chủ đề phía sau, ngoài việc quên để unexport UnicastRemoteObjects không?

Answer 1

Chắc chắn, tôi đã gặp lỗi trong mã khiến một trong nhiều (các) UnicastRemoteObject của tôi không tự unexport khi ứng dụng gọi được thực hiện bằng cách sử dụng nó. Vì vậy, câu trả lời là:

Bỏ qua tất cả các UnicastRemoteObject trong một JVM đang chạy là đủ để đóng tất cả các chuỗi không phải daemon.

Answer 2

Có vẻ như bạn đã giải quyết được vấn đề của bạn @ Nhưng với hậu thế, tôi nghĩ tôi muốn quảng bá nhận xét của mình cho câu trả lời. Bất cứ khi nào tôi có một loại đăng ký/unregister của mô hình tôi chắc chắn để quản lý chúng thông qua một đối tượng singleton. Bằng cách này bạn có một nơi để đi tìm ra đối tượng nào không được đăng ký. Phơi bày điều này trong JMX cũng là một chiến thắng.

Nội dung nào đó giống như mã sau sẽ tốt. Nó sẽ cho phép bạn đăng nhập hoặc truy vấn JMX để xem những đối tượng nào đã bị ràng buộc vào sổ đăng ký nhưng vẫn chưa được gắn kết.

public class UnicastRegistry { 
    private static Registry registry; 
    private static UnicastRegistry singleton; 
    // private to force the singleton 
    private UnicastRegistry() throws RemoteException { 
     registry = LocateRegistry.createRegistry(9977); 
    } 
    public static UnicastRegistry createSingleton() throws RemoteException { 
     if (singleton == null) { 
      singleton = new UnicastRegistry(); 
     } 
     return singleton; 
    } 
    public void register(String label, Remote obj) throws Exception { 
     registry.bind(label, obj); 
    } 
    public void unregister(String label) throws Exception { 
     Remote remote = registry.lookup(label); 
     registry.unbind(label); 
     if (remote instanceof UnicastRemoteObject) { 
      UnicastRemoteObject.unexportObject(remote, true); 
     } 
    } 
    public void unregisterAll() throws Exception { 
     for (String label : registry.list()) { 
      unregister(label); 
     } 
    } 
    public void printStillBound() throws Exception { 
     String[] stillBound = registry.list(); 
     if (stillBound.length > 0) { 
      System.out.println("Still bound = " + Arrays.toString(stillBound)); 
     } 
    } 
}