Yt-dlp를 사용한 라즈베리파이 프로젝트 -완-

Notice

Recent Posts

Recent Comments

Link

« 2025/08 »
일	월	화	수	목	금	토
					1	2
3	4	5	6	7	8	9
10	11	12	13	14	15	16
17	18	19	20	21	22	23
24	25	26	27	28	29	30
31

Tags more

Archives

Today

Total

관리 메뉴

yongsa0221의 고물상

Yt-dlp를 사용한 라즈베리파이 프로젝트 -완- 본문

예토전생

Yt-dlp를 사용한 라즈베리파이 프로젝트 -완-

yongsa0221 2024. 9. 2. 18:11

프로젝트 동작 구조

완성된 프로젝트는 다음과 같이 동작한다.

provider - consumer 관계로 접근하여 구현하려고 하였다.

사용자의 입력을 provider, 이에 따라 동작할 애플리케이션을 consumer로 생각하고 구조를 잡았다.

이벤트 기반의 프로그래밍을 참고하여 리스너와 핸들러를 구현하는 방식으로 진행하였다.

사용자 입력에 따라 메시지가 BlockingQueue를 사용하여 입력되며 리스너는 이 큐에 있는 사용자 입력에 따른 메시지를 소비하여 핸들러에게 전달하는 구조이다.

public class StateMessageQueue {
    private BlockingQueue<StateMessage> queue;
    public StateMessageQueue() {
        this.queue = new LinkedBlockingQueue<>();
    }

    public boolean offer(StateMessage message) {
        return queue.offer(message);
    }

    public StateMessage poll(int time, TimeUnit timeunit) throws InterruptedException {
        return queue.poll(time, timeunit);
    }
}

public class StateMessageListener implements Runnable {
    private final StateMessageQueue queue;
    private final StateMessageHandler handler;
    private final RunFlag flag;
    private boolean runnable = true;

    @Autowired
    public StateMessageListener(StateMessageQueue queue, StateMessageHandler handler, RunFlag flag) {
        this.queue = queue;
        this.handler = handler;
        this.flag = flag;
    }

    @Override
    public void run() {
        while (runnable) {
            synchronized (queue) {
                try {
                    queue.wait();
                    StateMessage message = queue.poll(3, TimeUnit.SECONDS);
                    runnable = handler.handle(message);
                    synchronized (flag) {
                        if (!runnable) {
                            flag.setFalse();
                        }
                        flag.notifyAll();
                    }
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        }
        System.out.println(this.toString() + "terminated");
    }

@Autowired
    public StateMessageHandler(YoutubeMusicPlayer musicPlayer, YoutubeAudioSearcher searcher, CactusController cactus) {
        this.musicPlayer = musicPlayer;
        this.searcher = searcher;
        this.cactus = cactus;
    }

    public boolean handle(StateMessage stateMessage) {
        State state = stateMessage.getState();
        String value = stateMessage.getValue();
        System.out.println(value);
        switch (state) {
            case PLAY -> {
                YoutubeAudio audio = searcher.getYoutubeAudioFrom(value);
                musicPlayer.downLoadAndPlay(audio);
                cactus.dance();
            }
            case STOP -> {
                musicPlayer.stopMusic();
                cactus.stop();
            }
            case PAUSE -> {
                musicPlayer.pauseMusic();
                cactus.stop();
            }
            case RESUME -> {
                musicPlayer.resumeMusic();
                cactus.dance();
            }
            case VOLUME -> {
                if (value.equals("up")) {
                    musicPlayer.volumeUp();
                } else if (value.equals("down")) {
                    musicPlayer.volumeDown();
                } else {
                    musicPlayer.setVolumeLevel(value);
                }
            }
            case EXIT -> {
                musicPlayer.stopMusic();
                cactus.stop();
                cactus.close();
                return false;
            }
        }
        return true;
    }