Как передать значение клиенту?

Question

[newbie_at_code]

Код который принимает и отвечает на сообщения клиента:

package primer;

import java.io.IOException;
import java.util.Timer;

import org.springframework.stereotype.Component;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;




@Component
public class SocketTextHandler extends TextWebSocketHandler {
	public static int hours = 0;
	public static int minutes = 0;
	public static int seconds = 0;
	public static int elapsedTime = 0;
	boolean started = false;



	@Override
	public void handleTextMessage(WebSocketSession session, TextMessage message) 

			throws InterruptedException, IOException {

		String clientMessage = message.getPayload();
		if (clientMessage.startsWith("start")) {	
			new Timer().scheduleAtFixedRate(new qtask(), 0, 1000);

			try {
				
				Thread.sleep(1000);
				session.sendMessage(new TextMessage(hours+":"+minutes+":"+seconds));
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				
			}
	
		}
					
				}		}

Код timertask, который выполняет секундомер:

package primer;

import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.TimerTask;

public class qtask extends TimerTask {
private String xtime;
	public static int hours = 0;
	public static int minutes = 0;
	public static int seconds = 0;
	public static int elapsedTime = 0;
	boolean started = false;
	
	String seconds_string = String.format("%02d", seconds);
	String minutes_string = String.format("%02d", minutes);
	String hours_string = String.format("%02d", hours); 
	
    @Override
    public  void run() {
    	elapsedTime=elapsedTime+1000;
		hours = (elapsedTime/3600000);
		minutes = (elapsedTime/60000)%60;
		seconds = (elapsedTime/1000)%60;

		
 
	 
 }
   
	}

Как сделать так, что бы код qtask отправлял значение клиенту?

Comments

[newbie_at_code]

Dmitry Roo, добрый день, можете подсказать ?

[Dmitry Roo]

newbie_at_code, Я вообще-то уже отвечал на этот вопрос тут.

Почитайте Java Code Conventions. Имя класса пишется с большой буквы.

У меня встречный вопрос: что присходит в классе qtask? Там таймер ваш работает? Где хранится его текущее состояние?

[newbie_at_code]

Dmitry Roo, в классе qtask секундомер, так же этот класс отправляет текущее значение секундомера, таймер выполняет это каждую секунду. Сам по себе qtask работает правильно, вопрос только в том, как эти значение выводить клиенту?

[Dmitry Roo]

newbie_at_code, как вы узнали, что "qtask работает правильно"?

[newbie_at_code]

Dmitry Roo,

package testTimer;


import java.util.Timer;

public class timer {
	public static void main (String[] args) {
	new Timer().scheduleAtFixedRate(new qtask(), 0, 1000);

	
		try {
		
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
}
}

[newbie_at_code]

newbie_at_code, только в qtask дописал System.out.println(hours_string+":"+minutes_string+":"+seconds_string);

Answer 1

[Dmitry Roo]

1. Добавьте в qtask в метод run что, что будет устанавливать значение для xtime
2. Сделайте в qtask геттер этого значения.
3. Сделайте qtask сервисом, добавив аннотации @Component или @Service
4. Добавьте его как поле в SocketTextHandler
5. Получайте информацию с помощью метода, который в реализовали в п.2

Должно получиться как-то так:

@Component
public class Qtask extends TimerTask {
  private String xtime;
  public int hours = 0;
  public int minutes = 0;
  public int seconds = 0;
  public int elapsedTime = 0;
  boolean started = false;

    @Override
    public  void run() {
    elapsedTime=elapsedTime+1000;
    hours = (elapsedTime/3600000);
    minutes = (elapsedTime/60000)%60;
    seconds = (elapsedTime/1000)%60 
     // TODO :: set xtime
    xtime = String.valueOf(elapsedTime);
 }
  
    public String getXtime() {
      return this.xtime;
    }
}

@Component
public class SocketTextHandler extends TextWebSocketHandler {

  @Autowired
   private Qtask qtask;

  @Override
  public void handleTextMessage(WebSocketSession session, TextMessage message) 

      throws InterruptedException, IOException {

    String clientMessage = message.getPayload();
    if (clientMessage.startsWith("start")) {	
      new Timer().scheduleAtFixedRate(qtask, 0, 1000);

      try {
        
        Thread.sleep(1000);
        session.sendMessage(new TextMessage(qtask.getXtime()));
      } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
        
      }
  
    }
          
        }		
}

Comments

[newbie_at_code]

Dmitry Roo Сделал так, как Вы написали. Теперь когда я отправляю серверу команду start, сервер дисконектит клиента с сервера.

[Dmitry Roo]

newbie_at_code, изучайте логи, ищите ошибки. Код только в качестве направления, примера.

[newbie_at_code]

Dmitry Roo, ясно, спасибо! Подскажите, возможно ли как-то отправлять сообщение клиенту из класса qtask, потому что если оставить так, то значение счетчика отправиться только один раз, т.к. отправка сообщения клиенту вне таймера.

[Dmitry Roo]

newbie_at_code, вот ваш пример:

import java.util.Timer;
import java.util.TimerTask;

class MyTimer {
    public static void main(String[] args) {
        var qtask = new Qtask();
 
        new Timer().scheduleAtFixedRate(qtask, 0, 1000); // запускается Timer

        for (int i = 0; i < 10; i++) {
            try {
                Thread.sleep(1000);   // Ждем секунду
                System.out.println(qtask.getXtime()); // Забираем значение xtime
            } catch (Exception ignored) {

            }
        }

        System.exit(0);
    }
}

class Qtask extends TimerTask {
    private String xtime;
    public int hours = 0;
    public int minutes = 0;
    public int seconds = 0;
    public int elapsedTime = 0;

    @Override
    public void run() {
        elapsedTime = elapsedTime + 1000;
        hours = (elapsedTime / 3600000);
        minutes = (elapsedTime / 60000) % 60;
        seconds = (elapsedTime / 1000) % 60;
        xtime = String.valueOf(elapsedTime);
    }

    public String getXtime() {
        return xtime;
    }
}