提问者:小点点

discord.py音乐机器人:如何组合播放和队列命令


你好,我正在尝试创建一个音乐机器人,但我想要它,这样我就可以播放音乐并使用相同的命令将其他音乐添加到队列中。我尝试过这样做,但我无法让它工作。这是播放和队列是两个独立命令的代码:

@bot.command(pass_context=True)
async def join(ctx):
    await bot.join_voice_channel(bot.get_channel('487315853482786820'))


@bot.command(pass_context=True)
async def leave(ctx):
    voice_client = bot.voice_client_in(ctx.message.server)
    await voice_client.disconnect()


players = {}
queues = {}


def check_queue(id):
    if queues[id] != []:
        player = queues[id].pop(0)
        players[id] = player
        player.start()


@bot.command(pass_context=True)
async def play(ctx, url):
    server = ctx.message.server
    voice_client = bot.voice_client_in(server)
    player = await voice_client.create_ytdl_player(url, after=lambda: check_queue(server.id))
    players[server.id] = player
    player.start()


@bot.command(pass_context=True)
async def queue(ctx, url):
    server = ctx.message.server
    voice_client = bot.voice_client_in(server)
    player = await voice_client.create_ytdl_player(url, after=lambda: check_queue(server.id))

    if server.id in queues:
        queues[server.id].append(player)
    else:
        queues[server.id] = [player]
    await bot.say('Video queued.')


@bot.command(pass_context=True)
async def pause(ctx):
    id = ctx.message.server.id
    players[id].pause()


@bot.command(pass_context=True)
async def stop(ctx):
    id = ctx.message.server.id
    players[id].stop()


@bot.command(pass_context=True)
async def resume(ctx):
    id = ctx.message.server.id
    players[id].resume()

共1个答案

匿名用户

您需要某种队列系统,其中歌曲请求存储在队列中,并需要一个循环来检查队列中是否有任何项目,如果可用,则获取队列中的第一个项目。如果队列中没有歌曲,则循环等待直到添加歌曲。您可以使用asyncio. Queue()asyncio.Event()来执行此操作。

import asyncio
from discord.ext import commands

client = commands.Bot(command_prefix='!')
songs = asyncio.Queue()
play_next_song = asyncio.Event()


@client.event
async def on_ready():
    print('client ready')


async def audio_player_task():
    while True:
        play_next_song.clear()
        current = await songs.get()
        current.start()
        await play_next_song.wait()


def toggle_next():
    client.loop.call_soon_threadsafe(play_next_song.set)


@client.command(pass_context=True)
async def play(ctx, url):
    if not client.is_voice_connected(ctx.message.server):
        voice = await client.join_voice_channel(ctx.message.author.voice_channel)
    else:
        voice = client.voice_client_in(ctx.message.server)

    player = await voice.create_ytdl_player(url, after=toggle_next)
    await songs.put(player)

client.loop.create_task(audio_player_task())

client.run('token')