Несколько запросов сервлета не могут вызвать метод объекта JMS

Question

У меня есть объект JMS, добавленный для запроса объекта, и в методе doPost() метод метода объекта вызывается для получения текущих данных темы, которые будут отправлены клиенту в ответ непрерывно.

В другом запросе пользователя одновременно, я не вижу в методе doPost(), получая сообщение, вызываемое или, вернее, получаю пустую/нулевую строку из вызова.

Как заставить метод реагировать на одновременные запросы/пользователей.

Об отладке: во время отладки в затмении иногда я вижу, что оба потока получают данные getMessage.

<jms:listener-container connection-factory="connectionFactory" task-executor="jmsTaskExecutor" destination-type="topic" concurrency="5">  
    <jms:listener destination="abc.topic" ref="abc" method="receive" />  
</jms:listener-container> 

<bean name="jmsTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> 
    <property name="corePoolSize" value="2"/> 
    <property name="maxPoolSize" value="50"/>  
    <property name="threadNamePrefix" value="some-queue-thread"/> 
</bean> 

<bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate"> 
    <property name="connectionFactory" ref="connectionFactory"/> 
    <property name="pubSubDomain" value="true"/> 
</bean> 


@Component("abc") 
public class abc { 

private String msg; 

public synchronized void receive(String msg){  
    this.msg = msg;  
} 


public synchronized String getMessage(){   
    return msg;  
} 
} 

@Component 
@Controller 
public class ForwardController extends ServletForwardingController 
{ 
@Autowired 
abc topicObject; 

@Override 
@RequestMapping("/xyzPath") 
protected ModelAndView handleRequestInternal(HttpServletRequest request, HttpServletResponse response) throws Exception {  
     request.setAttribute("autowired", topicObject); 
     request.getRequestDispatcher("/xyz").forward(request, response); 
    }   
return null; 
} 

@WebServlet("/xyz") 
public class xyz extends HttpServlet { 
protected void doPost(HttpServletRequest request, HttpServletResponse response) { 

abc topicObject = request.getAttribute("autowired"); 

while(true){   
    System.out.println("start"+Thread.currentThread.getId()); 
    String msg = topicObject.getMessage(); 
    response.getWriter.write(msg); 
    System.out.println("stop"+Thread.currentThread.getId()); 
    } 
} 
} 

Что такое правильный способ вызова topicObject.getMessage() одновременно

Answer 1

Удалить аннотацию @Async. Я не уверен, что вы намеревались сделать, но это не так.

От Javadoc:

Однако тип возврата ограничен либо void или Future.

А из Spring framework documentation:

@Async аннотации могут быть предоставлены по методу так, что вызов этого метода будет происходить асинхронно. Другими словами, вызывающий абонент будет немедленно возвращаться после вызова и фактического выполнения , метод будет выполняться в задаче, которая была отправлена ​​в Spring TaskExecutor.

Другими словами, с @Async код не выполняется немедленно, но позже в другом потоке, но он немедленно возвращается. Таким образом, для вашего getMessage вы предоставили тип возвращаемого значения, который не поддерживается, и приводит к неопределенному поведению (случайный, даже в вашем случае).

Для метода receive это также не то, что вы хотите, потому что оно перенесет назначение на message.

Решение: Удалите оба аннотаций @Async и сделать оба метода synchronized так, что вы правильно опубликовать изменения в message переменной, которая делает его видимым во всех потоках.