Почему SseEmitter шлет сообщения по кругу?

Question

[artemfisher]

Никак не могу решить проблему. Каждый раз вызывается метод getCatalogs() с клиента.
Также интересно, что данные, которые должны передаваться по одному, передаются разом.
Т.е. сразу на клиент приходит 4 строки из цикла и строка, которая идет после цикла.

В логах сервера и в браузере показывает что постоянно происходит вызов метода getCatalogs().

@GetMapping("/getcatalogs")
	public SseEmitter getCatalogs() throws IOException
	{
		String url="https://market.yandex.ru/catalog--elektronika/61590?hid=198119";		
						
		Document document = Jsoup.connect(url).get();
		Elements elements = document.select(".egKyN._2jA_3._3a7xr");		
		
		List<Element> elems = elements.stream().toList();
		
		if(elems.size()>4)
			elems=elems.subList(0, 4);
		
		final List<Element> elems2 = elems;
		
		logger.info("elems2:"+elems2.size());
		
		ExecutorService executor = Executors.newCachedThreadPool();
		
		SseEmitter emitter = new SseEmitter();
		
		executor.execute(()->
		{		
			try
			{
				for(Element el:elems2)
				{
					String s = el.text()+" - "+el.attr("href");		
					emitter.send(s);
				}
				
				emitter.send("The parsing of the catalogs list is completed ");
			}
			catch(IOException ex)
			{
				emitter.completeWithError(ex);
			}
			finally
			{				
				emitter.complete();
			}	
		});	
		
		return emitter;		
	}

<script>
$('#parser_start').on('click', function() {	
	
	$(this).prop("disabled", true);
	url =  $('#catalog_url').val();
	//url="/SpringMvc/parser/getcatalogs";
	var sse = new EventSource(url);
	sse.onmessage = function (evt) {
	    var el = document.getElementById('result');
	    el.appendChild(document.createTextNode(evt.data));
	    el.appendChild(document.createElement('br'));	    
	};
	
	
});
</script>

Comments

[My1Name]

Зачем вы создаёте в теле метода pool потоков Executors.newCachedThreadPool(); ? Тут нужен SingleThreadExecutor() коль вы создаёте поток на каждый EventSource.

Если Elements - объект JSOUP, то эта строка тоже лишняя: List<Element> elems = elements.stream().toList();
Вы получаете массив элементов, подобно JavaScript (select). Их можно просто перебрать. Stream не нужен. См. пример

сразу на клиент приходит 4 строки из цикла и строка, которая идет после цикла.

Вероятно у вас 4 DOM элемента (elements) на каждый из которых, вы создаёте новый Thread. Попробуйте добавить Thread.sleep(1000); после emitter.send(s);

Почему SseEmitter шлет сообщения по кругу?

SseEmitter по умолчанию открывает поток на 30 секунд (если я не ошибаюсь) и, в течении этого времени работает однонаправленное socket (WebSocket) соединение. Время работы можно задать следующим образом:SseEmitter emitter = new SseEmitter((long) 10000);

[artemfisher]

Спасибо. SingleThreadExecutor() тоже пробовал, все равно ничего не меняется.
Подозреваю, что проблема с клиентской стороны. Ибо запросы оттуда идут постоянно к методу контроллера.
По логам в браузере предполагаю, что проблема в том, что var sse = new EventSource(url) вызывает метод контролера, а не просто ждет сообщений от него как должен.
Но не могу понять почему, вызывается повторно. Перезагрузки всей страницы не происходит же, только перерисовка внутри div

[artemfisher]

My1Name,
Я пробовал и не создавать для каждого EventSource. Ничего не меняется. Выше в комментарии добавил пояснение.

[My1Name]

artemfisher,

Подозреваю, что проблема с клиентской стороны.

Клиент условно "висит" на канале столько, сколько выделено времени для работы SseEmitter. Соединение создаётся один раз. Клиент только слушает события посылаемые сервером.

[artemfisher]

My1Name,
Хорошо, так в чем проблема может быть, почему отправляет без конца сообщения эмиттер?

[My1Name]

artemfisher,

почему отправляет без конца сообщения эмиттер?

"без конца" это сколько?)) 30 секунд?

Я не читал дословно документацию, но на сколько я знаю SseEmitter работает по UDP протоколу. Если он постоянно посылает сообщения, то сервер подвис в каком-то цикле.

По логам в браузере предполагаю, что проблема в том, что var sse = new EventSource(url) вызывает метод контролера, а не просто ждет сообщений от него как должен.

А как иначе? - Так работает фреймворк Spring: Каждое действие с url - это обращение ̶(в̶ы̶з̶ы̶в̶а̶е̶т̶) к соответствующему методу контроллера по указанному адресу. И дело не в SseEmitter, а в том, как вы понимаете работу фреймворка... Рекомендую для начала разобраться со Спрингом, а потом строить более сложные программы.