@Message Annotation funktioniert nicht, wenn ich Atmosphären-Chat-Multiroom von Atmosphäre-Proben

Question

Ich habe über dieses Problem für eine lange Zeit gesucht, aber keine Lösung kommt für mich.

Hier ist ein Code (ich habe gerade einige System.out.println Sätze hinzugefügt).

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())); 
    } 
} 

Wenn ich diese Probe in IntelliJ IDEA laufen, kann die websocket etablieren. Und alle Funktionen funktioniert gut außer @Message Annotation, kann ich wählen, dass ein Chatroom bedeutet, dass @Ready Annotation funktioniert Ursache Konsolenprotokoll druckt wie unten.

Client 6c981440-0ae6-43ed-be40-95dfad23d586 angeschlossen.

Wenn ich meinen Browser zu schließen, ist Konsolprotokoll

Kunde 6c981440-0ae6-43ed-be40-95dfad23d586 die Verbindung geschlossen

die @Disconnect Arbeiten bedeutet.

Aber ich tippe einen Namen in input und klicken Sie auf Enter. Nichts ist passiert.

Jeder kann helfen wird geschätzt. Danke im Voraus.

PS: Die Laufumgebung ist JDK1.7, Tomcat7 und Atmosphäre-Runtime-Version ist 2.4.3. Ich habe dieses gestern debuggen, nachdem ich einen Namen eingegeben habe, IllegalArgumentException wurde in Code unten eingefangen.

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; 
} 

die Code ist in org \ Atmosphäre \ atmosphären runtime \ 2.4.3 \ Atmosphäre-runtime-2.4.3.jar! \ Org \ Atmosphäre \ config \ verwaltet \ Invoker.class

Answer 1

Ich habe dieses Problem, und möglicherweise die encoders und decoders dieses Problem verursacht, versuchen, Ihre Methode Parameter auf String zu ändern.