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

activemq 重复接收到消息

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

    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   ·   实用小工具   ·   2226 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 22ms · UTC 01:28 · PVG 09:28 · LAX 17:28 · JFK 20:28
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.