实战教程：Java消息类（Message）的运用实例 - 实例4: onMessage方法解析

import org.atmosphere.config.service.Message; //导入依赖的package包/类
@Message(decoders = {ActivityDTOJacksonDecoder.class})
public void onMessage(AtmosphereResource atmosphereResource, ActivityDTO activityDTO) throws IOException {
    AtmosphereRequest request = atmosphereResource.getRequest();
    activityDTO.setSessionId(request.getSession().getId());
    activityDTO.setIpAddress(request.getRemoteAddr());
    activityDTO.setTime(dateTimeFormatter.print(Calendar.getInstance().getTimeInMillis()));
    String json = jsonMapper.writeValueAsString(activityDTO);
    log.debug("Sending user tracking data {}", json);
    for (AtmosphereResource trackerResource : b.getAtmosphereResources()) {
        trackerResource.getResponse().write(json);
    }
}