Пример Spring Scheduler (проект Spring boot и Vaadin 14) - PullRequest
Новая
       7

Пример Spring Scheduler (проект Spring boot и Vaadin 14)

0 голосов
/ 20 января 2020

Я создал чат для общения. Для интерфейса, который я использую vaadin, я хочу протестировать чат, необходимо, чтобы при открытии чата он запускался каждую 1 секунду (привет 1, привет 2, привет 3 .. .....) я написал шедулер, но как это можно исправить? Кажется, я написал это неправильно.

MainView

    public class MainView extends VerticalLayout {

    private final MessagesInfoManager messagesInfoManager;
    private final RestService restService;
    private String username;

    @Autowired
    public MainView(RestService restService) {
        this.messagesInfoManager = MessageConfigurator.getInstance().getChatMessagesInfoManager();
        addClassName("main-view");
        setSizeFull();
        setDefaultHorizontalComponentAlignment(Alignment.CENTER);

        H1 header = new H1("Vaadin Chat");
        header.getElement().getThemeList().add("dark");

        add(header);

        askUsername();
        this.restService = restService;
    }

    private void askUsername() {
        HorizontalLayout layout = new HorizontalLayout();
        TextField usernameField = new TextField();
        Button startButton = new Button("Start chat");

        layout.add(usernameField, startButton);

        startButton.addClickListener(click -> {
            username = usernameField.getValue();
            remove(layout);
            showChat(username);
        });

        add(layout);
    }

    private void showChat(String username) {
        MessageList messageList = new MessageList();

        List<Message> lasts = restService.getLast();
        for (Message message : lasts) {
            messageList.add(new Paragraph(message.getFrom() + ": " + message.getMessage()));
        }

        add(messageList, createInputLayout(username, messageList));
        expand(messageList);
    }

    private Component createInputLayout(String username, MessageList messageList) {
        HorizontalLayout layout = new HorizontalLayout();
        layout.setWidth("100%");

        TextField messageField = new TextField();
        messageField.addKeyDownListener(Key.ENTER, keyDownEvent -> sender(messageField, messageList));
        Button sendButton = new Button("Send");
        sendButton.addThemeVariants(ButtonVariant.LUMO_PRIMARY);

        layout.add(messageField, sendButton);
        layout.expand(messageField);

        messageField.addFocusListener(event -> {
            for (Message message : messagesInfoManager.getMessagesByUI(getUI())) {
                if (!message.getFrom().equals(username)) {
                    message.setUnread(false);
                    this.restService.updateMessage(message.getId(), message);
                }
            }
        });

        sendButton.addClickListener(click -> sender(messageField, messageList));
        messageField.focus();

        return layout;
    }

    private void sender(TextField textField, MessageList messageList) {
        Message message = new Message(username, textField.getValue());
        message = restService.saveMessage(message);
        messagesInfoManager.updateMessageUIInfo(new MessageInfo(messageList, message, this));
        textField.clear();
        textField.focus();
    }




    @Scheduled (fixedDelay = 1000)
    public void test() {
    System.out.println("Hello");
    }
    }

Планировщик в Mainview 

    @Scheduled (fixedDelay = 1000)
    public void test() {
    System.out.println("Hello");
    }

Мой пример 

@Scheduled (fixedDelay = 1000)
public void test() {
    count++; 

    System.out.println("Hello"+count);


}

1 Ответ

1 голос
/ 20 января 2020

Включить планирование

Вы можете включить планирование, просто добавив аннотацию @EnableScheduling в основной класс приложения или в любой класс конфигурации.

Задачи планирования

Планирование задачи так же просто, как аннотирование метода с помощью аннотации @Scheduled.

В следующем примере метод execute () планируется запускать каждую секунду. Метод execute () должен вызывать требуемый метод обслуживания lke getAllMessages () в этом примере. 

@EnableScheduling
public class MainView extends ... {

    // Existing Code

    @Autowired
    private MessageServiceImpl messageService;

    @Scheduled(fixedRate = 1000)
    public void execute() {
        messageService.getAllMessages();
    }

}

Типы планирования

  1. Планирование с фиксированным Скорость

    execute() можно запланировать для запуска с фиксированным интервалом, используя параметр fixedRate. 

    @Scheduled(fixedRate = 2000)

  2. Планирование с фиксированным Можно запланировать запуск метода delay

    execute() с фиксированной задержкой между завершением последнего вызова и началом следующего, используя параметр fixedDelay. 

    @Scheduled(fixedDelay = 2000)

  3. Планирование с начальной задержкой и фиксированной скоростью / фиксированной задержкой

    initialDelay Параметр с fixedRate и fixedDelay для задержки первого выполнения. 

    @Scheduled(fixedRate = 2000, initialDelay = 5000)

    @Scheduled(fixedDelay= 2000, initialDelay = 5000)

  4. Можно запланировать запуск метода cron

    execute() на основе выражения cron с использованием параметра cron. 

    @Scheduled(cron = "0 * * * * *")
...