V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
BernardMe
V2EX  ›  问与答

activemq 重复接收到消息

  •  
  •   BernardMe · 2020-05-28 14:15:02 +08:00 · 756 次点击
    这是一个创建于 1430 天前的主题,其中的信息可能已经有所发展或是发生改变。

    SpringBoot 项目的两个不同模块之间

    发送端

     //线程池
    	private static ExecutorService executorService = new ThreadPoolExecutor(2, 200, 5, TimeUnit.SECONDS,
    			new ArrayBlockingQueue<Runnable>(200), new ThreadPoolExecutor.DiscardOldestPolicy());
    	/**
    	 * 发送通知
    	 * @param list
    	 */
    	public void sendTeacherMsg(List<xxxPo> list) {
    		executorService.submit(new Runnable() {
    			@Override
    			public void run() {
    				queueSender.send("xxx.xxxSender", JSON.toJSONString(list));
    				logger.info("成功发送了一条 JMS 消息, List<xxxPo>总个数:" + JSON.toJSONString(list.size()));
    			}
    		});
    	}
    

    接收端

    
    	/**
    	 * @description 信息消息监听
    	 */
    	@JmsListener(destination = "xxx.xxxSender")
    	@Override
    	public void onMessage(Message message) {
    		try {
    			System.out.println("接受到了了");
    			List<xxxPo> list = JSONObject.parseObject(((ObjectMessage) message).getObject().toString(), new TypeReference<List<xxxPo>>(){}.getType());
    		
    		} catch (JMSException e) {
    			e.printStackTrace();
    			log.error("QylZuowenListener 获取 JMS 消息失败", e);
    		}
    	}
    

    发送端定时发送一次 但是,接收端却意外接受到 7 次,重启两个模块也还是这样

    请问这个怎么解决

    目前尚无回复
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   2976 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 25ms · UTC 12:55 · PVG 20:55 · LAX 05:55 · JFK 08:55
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.