无法优雅地关闭wildfly

Question

当我点击右键 - >停止时，萤火虫9不会在eclipse中关闭，但是当我点击停止在控制台时，萤火虫9会关闭。

当试图优雅的关闭，在控制台输出：

18:36:08,342 INFO [org.jboss.as.server] (management-handler-thread - 5) WFLYSRV0211: Suspending server 
18:36:08,345 INFO [org.jboss.as.server] (Thread-2) WFLYSRV0220: Server shutdown has been requested. 
18:36:08,428 INFO [org.wildfly.extension.undertow] (ServerService Thread Pool -- 81) WFLYUT0022: Unregistered web context: /csbasement 
18:36:08,441 INFO [org.ocpsoft.rewrite.servlet.RewriteFilter] (ServerService Thread Pool -- 81) RewriteFilter shutting down... 
18:36:08,442 INFO [org.ocpsoft.rewrite.servlet.RewriteFilter] (ServerService Thread Pool -- 81) RewriteFilter deactivated. 
18:36:08,460 INFO [org.wildfly.extension.undertow] (MSC service thread 1-1) WFLYUT0019: Host default-host stopping 

服务器的状态停留在后停止，没有停止过。 5分钟左右后，日食对话未能停止服务器，这在控制台：

19:29:11,600 WARN [com.arjuna.ats.arjuna] (Transaction Reaper) ARJUNA012117: TransactionReaper::check timeout for TX 0:ffffc0a80104:6ad8fb66:5637aa44:c in state RUN 
19:29:11,601 WARN [com.arjuna.ats.arjuna] (Transaction Reaper Worker 0) ARJUNA012095: Abort of action id 0:ffffc0a80104:6ad8fb66:5637aa44:c invoked while multiple threads active within it. 
19:29:11,601 WARN [com.arjuna.ats.arjuna] (Transaction Reaper Worker 0) ARJUNA012108: CheckedAction::check - atomic action 0:ffffc0a80104:6ad8fb66:5637aa44:c aborting with 1 threads active! 
19:29:11,602 WARN [com.arjuna.ats.arjuna] (Transaction Reaper Worker 0) ARJUNA012121: TransactionReaper::doCancellations worker Thread[Transaction Reaper Worker 0,5,main] successfully canceled TX 0:ffffc0a80104:6ad8fb66:5637aa44:c 

后，即使我得到404试图访问该Web应用程序的页面时的状态开始。我不确定错误中的含义：Unregistered web context: /csbasement。 csbasement是webapp的名称。另外，当使用干净的webapp状态保持启动，所以我必须停止服务器，清理并重新启动它。

当开始我有这个错误，但能正常开机：

19:17:16,344 ERROR [org.jboss.remoting.remote.connection] (XNIO-1 I/O-2) JBREM000200: Remote connection failed: java.io.IOException: An established connection was aborted by the software in your host machine 

编辑：

@Eager 
@Named 
@ApplicationScoped 
public class LaunchBackgroundTasks { 

    @EJB 
    private TwitterLatestTweetInterface twitterService; 
    private LinkedBlockingQueue<Tweet> msgList; 

    @PostConstruct 
    public void init() { 
     twitterService.makeLatestsTweets(); 
    } 
} 

@Stateless 
public class TwitterLatestTweets { 
    private LinkedBlockingQueue<Tweet> tweets; 
    @Inject 
    private LaunchBackgroundTasks caller; 


    @Asynchronous 
    public void makeLatestsTweets() { 
      ... 
     while (!hosebirdClient.isDone()) { 
      try { 
       String msg = msgQueue.take(); 
       Tweet tweet = format(msg); 
       tweets.put(tweet); 
       caller.setMsgList(tweets); 

      } catch (InterruptedException e) { 
       hosebirdClient.stop(); 
       e.printStackTrace(); 
      } 
     } 
    } 

而且我得到了鸣叫一个JSF页面上像这样：value="#{launchBackgroundTasks.msgList}"，这是“在玻璃鱼上工作”。

这并不异步启动（java @Asynchronous Methods: not running async）

@Eager 
@Named 
@ApplicationScoped 
public class TwitterLatestTweets { 

    private LinkedBlockingQueue<Tweet> tweets; 

    @PostConstruct 
    public void init() { 
     makeLatestsTweets(); 
    } 

    //notation not taken into account 
    @Asynchronous 
    public void makeLatestsTweets() { 


     // hosebirdClient is twitter streaming so I'm getting tweets as long as the app is alive. 
     while (!hosebirdClient.isDone()) { 
      try { 
       String msg = msgQueue.take(); 
       Tweet tweet = format(msg); 
       tweets.put(tweet); 
       } 
      } catch (InterruptedException e) { 
       hosebirdClient.stop(); 
       e.printStackTrace(); 
      } 
     } 
    } 

Answer 1

我是个很固执使用@Asynchronous，因为我希望我的线程管理，但我只是不能让它那样工作。我无法找到中断异步方法的线程的方式。所以我回到了一个正常的线程来完成我想要的工作。

@Eager 
@Named 
@ApplicationScoped 
public class LaunchBackgroundTasks { 

    @EJB 
    TopStreamInterface topStream; 
    Thread twitterThread; 

List<Tweet> tweets; 

    @PostConstruct 
    public void init() { 
     tweets = new LinkedList<Tweet>(); 
     twitterThread = new Thread(new TwitterLatestTweets(this)); 
     twitterThread.start(); 

    } 

    @PreDestroy 
    public void destroyTwitterClient() { 
     twitterThread.interrupt(); 
    } 
} 

和螺纹：

public class TwitterLatestTweets implements Runnable { 

    private final static String BUNDLE_BASENAME = "configuration.twitter"; 
    private final static String CONSUMER_KEY = ResourceBundle.getBundle(
      BUNDLE_BASENAME).getString("consumerKey"); 
    private final static String CONSUMER_SECRET = ResourceBundle.getBundle(
      BUNDLE_BASENAME).getString("consumerSecret"); 
    private final static String TOKEN = ResourceBundle.getBundle(
      BUNDLE_BASENAME).getString("token"); 
    private final static String SECRET = ResourceBundle.getBundle(
      BUNDLE_BASENAME).getString("secret"); 
    // private LinkedBlockingQueue<Tweet> msgList; 
    private List<Long> userIds; 
    private int tweetListSize = 10; 

    TwitterLatestTweets(LaunchBackgroundTasks caller) { 
    this.caller = caller; 
    } 
     @Override 
    public void run() { 
     makeLatestsTweets(); 
    } 

    public void makeLatestsTweets() { 

     BlockingQueue<String> msgQueue = new LinkedBlockingQueue<String>(100); 
     StatusesFilterEndpoint hosebirdEndpoint = new StatusesFilterEndpoint(); 

     userIds = addFollowings(); 

     hosebirdEndpoint.followings(userIds); 

     Authentication hosebirdAuth = new OAuth1(CONSUMER_KEY, CONSUMER_SECRET, 
       TOKEN, SECRET); 

     Client client = new ClientBuilder().name("test") 
       .hosts(Constants.STREAM_HOST).endpoint(hosebirdEndpoint) 
       .authentication(hosebirdAuth) 
       .processor(new StringDelimitedProcessor(msgQueue)).build(); 

     client.connect(); 

     while (!client.isDone()) { 
      try { 
       String msg = msgQueue.take(); 
       //... 
       caller.setTweets(aTweetLinkedList); 
       } 
      } catch (InterruptedException e) { 
       System.out.println("twitter interrupted"); 
       client.stop(); 
       e.printStackTrace(); 
      } 
     } 
    } 
}