當我運行氛圍樣本的氣氛聊天多房間時，@Message註解不起作用

Question

我已經搜索了很久，但沒有解決方案。

這是一些代碼（我剛剛添加了一些System.out.println短語）。

的web.xml

<display-name>Atmosphere Chat</display-name> 
<servlet> 
    <description>AtmosphereServlet</description> 
    <servlet-name>AtmosphereServlet</servlet-name> 
    <servlet-class>org.atmosphere.cpr.AtmosphereServlet</servlet-class> 
    <load-on-startup>0</load-on-startup> 
    <async-supported>true</async-supported> 
</servlet> 
<servlet-mapping> 
    <servlet-name>AtmosphereServlet</servlet-name> 
    <url-pattern>/chat/*</url-pattern> 
</servlet-mapping> 

ChatRoom.java

@ManagedService(path = "/chat/{room}") 
public class ChatRoom { 

    private final ConcurrentHashMap<String, String> users = new ConcurrentHashMap<String, String>(); 

    private final static String CHAT = "/chat/"; 

    @PathParam("room") 
    private String room; 

    @Inject 
    private BroadcasterFactory factory; 

    @Inject 
    private AtmosphereResourceFactory resourceFactory; 

    @Inject 
    private MetaBroadcaster metaBroadcaster; 

    private static Collection<String> getRooms(Collection<Broadcaster> broadcasters) { 
     Collection<String> result = new ArrayList<String>(); 
     for (Broadcaster broadcaster : broadcasters) { 
      if (!("/*".equals(broadcaster.getID()))) { 
       // if no room is specified, use '' 
       String[] p = broadcaster.getID().split("/"); 
       result.add(p.length > 2 ? p[2] : ""); 
      } 
     }; 
     return result; 
    } 
    @Ready(encoders = {JacksonEncoder.class}) 
    @DeliverTo(DeliverTo.DELIVER_TO.ALL) 
    public ChatProtocol onReady(final AtmosphereResource resource) { 
     System.out.println("Client " + resource.uuid() + " connected."); 
     return new ChatProtocol(users.keySet(), getRooms(factory.lookupAll())); 
    } 

    @Disconnect 
    public void onDisconnect(AtmosphereResourceEvent event) { 
     if (event.isCancelled()) { 
      System.out.println("Client " + event.getResource().uuid() + " unexpectedly disconnected."); 
     } else if (event.isClosedByClient()) { 
      System.out.println("Client " + event.getResource().uuid() + " closed the connection"); 
     } 
    } 

    @Message(decoders = {UserDecoder.class}) 
    public void onPrivateMessage(UserMessage user) { 
     System.out.println("Client " + user.getUser() + " send a message."); 
     String userUUID = users.get(user.getUser()); 
     if (userUUID != null) { 
      // Retrieve the original AtmosphereResource 
      AtmosphereResource r = resourceFactory.find(userUUID); 

      if (r != null) { 
       ChatProtocol m = new ChatProtocol(user.getUser(), " sent you a private message: " + user.getMessage().split(":")[1], users.keySet(), getRooms(factory.lookupAll())); 
       if (!user.getUser().equalsIgnoreCase("all")) { 
        factory.lookup(CHAT + room).broadcast(m, r); 
       } 
      } 
     } else { 
      ChatProtocol m = new ChatProtocol(user.getUser(), " sent a message to all chatroom: " + user.getMessage().split(":")[1], users.keySet(), getRooms(factory.lookupAll())); 
      metaBroadcaster.broadcastTo("/*", m); 
     } 
    } 

    @Message(encoders = {JacksonEncoder.class}, decoders = {ProtocolDecoder.class}) 
    public ChatProtocol onMessage(ChatProtocol message) throws IOException { 
     if (message.getMessage().contains("disconnecting")) { 
      users.remove(message.getAuthor()); 
      return new ChatProtocol(message.getAuthor(), " disconnected from room " + room, users.keySet(), getRooms(factory.lookupAll())); 
     } 

     if (!users.containsKey(message.getAuthor())) { 
      users.put(message.getAuthor(), message.getUuid()); 
      return new ChatProtocol(message.getAuthor(), " entered room " + room, users.keySet(), getRooms(factory.lookupAll())); 
     } 

     message.setUsers(users.keySet()); 
     return new ChatProtocol(message.getAuthor(), message.getMessage(), users.keySet(), getRooms(factory.lookupAll())); 
    } 
} 

當我運行在IntelliJ IDEA的這個樣本，WebSocket的可以建立。除了@Message註釋，我可以選擇一個聊天室的手段@Ready註釋工作導致如下所示的控制檯日誌打印。

客戶端6c981440-0ae6-43ed-be40-95dfad23d586連接。

當我關閉瀏覽器，控制檯日誌是

客戶6c981440-0ae6-43ed-be40-95dfad23d586關閉了連接

這意味着@Disconnect作品。

但我在input中輸入名稱，然後單擊enter。什麼都沒發生。

任何人都可以幫助，將不勝感激。提前致謝。

PS：運行環境是JDK1.7，tomcat7和atmosphere-runtime版本是2.4.3。我昨天調試了這個，在我輸入一個名字之後，IllegalArgumentException在下面的代碼中被捕獲。

public static Object invokeMethod(Method method, Object objectToInvoke, Object... parameters) { 
    Object objectToEncode = null; 
    boolean hasMatch = false; 

    try { 
     objectToEncode = method.invoke(objectToInvoke, method.getParameterTypes().length == 0?new Object[0]:parameters); 
     hasMatch = true; 
    } catch (IllegalAccessException var6) { 
     logger.trace("", var6); 
    } catch (InvocationTargetException var7) { 
     logger.error("", var7); 
    } catch (IllegalArgumentException var8) { 
     logger.trace("", var8); 
    } catch (Throwable var9) { 
     logger.error("", var9); 
    } 

    if(!hasMatch) { 
     logger.trace("No Method\'s Arguments {} matching {}", method.getName(), objectToInvoke); 
    } 

    return objectToEncode; 
} 

它的代碼是在組織\大氣\大氣運行\ 2.4.3 \大氣運行時2.4.3.jar！\組織\大氣\ CONFIG \管理\ Invoker.class

Answer 1

我遇到了這個問題，也許encoders和decoders引起了這個問題，請嘗試將您的方法參數更改爲String。