当我运行氛围样本的气氛聊天多房间时，@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。