0

我有以下代码：

控制器：

eventNotifier.saveMessage(buildMessage(message, room, sender));

事件通知器：

public void saveMessage(Message message){
        r.notify(EventConsumer.NEW_MESSAGE, Event.wrap(message));
    }

事件消费者：

@PostConstruct
    public void onStartUp() {
        r.on(Selectors.R(MESSAGE_SAVED), createEventAndPush());
        r.on(Selectors.R(NEW_MESSAGE), saveMessage());
        r.on(Selectors.R(EVENT), pushToMixpanel());
    }
public Consumer<Event<Message>> saveMessage(){
        System.err.println("Calling save async");
        return event -> messageRepo.save(event.getData());
    }

事实证明，该方法saveMessage从未被调用。我看到它在启动服务器过程中被调用过一次。

我不确定这是与反应堆相关还是与弹簧相关。

编辑：我将保存过程移至服务，没有任何改变

edit2：我记录了服务操作以查看发生了什么：

@Service
@Slf4j
public class MessageService {

    @Autowired MessageRepository messageRepo;

    @Transactional
    public void save(Message m){
        try{
            log.info("Saving...");
            messageRepo.save(m);
            log.info("Saved");
        }catch(Exception e){
            e.printStackTrace();
        }
    }

控制台中的输出是：

2016-09-09 16:24:42.152  INFO 45041 --- [      wa-chub-2] com.inkdrop.app.services.MessageService  : Saving...
2016-09-09 16:24:42.154  INFO 45041 --- [      wa-chub-2] com.inkdrop.app.services.MessageService  : Saved

没有来自 JPA 的日志，什么都没有！

4

2 回答 2

2

带有注解的方法@PostConstruct只会在 bean 创建期间被 spring 上下文调用一次。该onStartup()方法显式调用该saveMessage()方法，因此您会看到一次调用。

要在每次必须显式调用它时保存它，它不会神奇地完成。

于 2016-09-09T14:30:19.477 回答
1

我将引用@PostContructJavadoc：

PostConstruct 注解用于需要在依赖注入完成后执行任何初始化的方法。

所以它只会在你的bean初始化后执行一次。

于 2016-09-09T14:15:20.670 回答