Я пытаюсь использовать пример, приведенный в официальной документации Jersey SSE.
См. « 14.5.2. Асинхронная обработка SSE с EventSource » по ссылке ниже https://jersey.github.io/documentation/2.8/user-guide.html#example-simple-sse
Мой код, как показано ниже
Код клиента -
public class ClientSSEEventManager {
public void WaitForEvents() {
// Client client = ClientBuilder.newBuilder()
// .register(SseFeature.class).build();
// WebTarget target =
// client.target("http://localhost:8080/server/events");
//
// EventInput eventInput = target.request().get(EventInput.class);
// while (!eventInput.isClosed()) {
// final InboundEvent inboundEvent = eventInput.read();
// if (inboundEvent == null) {
// // connection has been closed
// break;
// }
// System.out.println(inboundEvent.getName() + "; "
// + inboundEvent.readData(String.class));
// }
Client client = ClientBuilder.newBuilder().register(SseFeature.class)
.build();
WebTarget target = client.target("http://localhost:8080/server/events");
EventSource eventSource = EventSource.target(target).build();
EventListener listener = new EventListener() {
@Override
public void onEvent(InboundEvent inboundEvent) {
System.out.println(inboundEvent.getName() + "; "
+ inboundEvent.readData(String.class));
}
};
eventSource.register(listener, "message-to-client");
eventSource.open();
}
}
public class MyApplication extends ResourceConfig {
public MyApplication(){
super(ClientSSEEventManager.class, SseFeature.class);
}
// Set<Class<?>> classes = new HashSet<Class<?>>() {
// /**
// *
// */
// private static final long serialVersionUID = 1L;
//
// { add(ClientSSEEventManager.class);
// }};
//
// @Override
// public Set<Class<?>> getClasses() {
// return classes;
// }
}
Затем в одном из методов действия я просто инициализирую прослушивание события следующим образом.
//Start listening to event from server
ClientSSEEventManager clientSSEEventManager = new ClientSSEEventManager();
clientSSEEventManager.WaitForEvents();
///
Клиентский Web.xml имеет следующие параметры инициализации:
<init-param>
<param-name>javax.ws.rs.Application</param-name>
<param-value>com.framework.MyApplication</param-value>
</init-param>
Код сервера -
@Path("events")
public class ServerSSEServerEventManager {
@GET
@Produces(SseFeature.SERVER_SENT_EVENTS)
public EventOutput getNotificationEvents(){
final EventOutput eventOutput = new EventOutput();
new Thread(new Runnable() {
@Override
public void run() {
try {
for (int i = 0; i < 10; i++) {
// ... code that waits 1 second
final OutboundEvent.Builder eventBuilder
= new OutboundEvent.Builder();
eventBuilder.name("message-to-client");
eventBuilder.data(String.class,
"Hello world " + i + "!");
final OutboundEvent event = eventBuilder.build();
eventOutput.write(event);
}
} catch (IOException e) {
throw new RuntimeException(
"Error when writing the event.", e);
} finally {
try {
eventOutput.close();
} catch (IOException ioClose) {
throw new RuntimeException(
"Error when closing the event output.", ioClose);
}
}
}
}).start();
return eventOutput;
}
}
Ожидаемый результат на стороне клиента выглядит следующим образом
message-to-client; Hello world 0!
message-to-client; Hello world 1!
message-to-client; Hello world 2!
message-to-client; Hello world 3!
message-to-client; Hello world 4!
message-to-client; Hello world 5!
message-to-client; Hello world 6!
message-to-client; Hello world 7!
message-to-client; Hello world 8!
message-to-client; Hello world 9!
Но на стороне клиента ничего не печатается. Я что-то пропустил здесь? У меня есть сомнения, client.Target должен иметь "http://:8080/server/events"? ИЛИ это должно быть просто "http://:8080/events"
Context Path
вашего приложения. Если вы развертываете какserver
, ваш путь должен бытьhttp://localhost:8080/server/events
. Я бы добавил некоторые журналы на стороне вашего сервера и добавил фильтр регистрации Джексона к вашему клиентуclient.register(new LoggingFilter(LOG, true));
, чтобы вы могли видеть, что ваш клиент отправляет/получает. - person Baldy   schedule 15.05.2014