最后更新于
https://api.telegram.org/bot${token}/getUpdateshttps://api.telegram.org/bot${token}/sendMessage?chat_id=${chat_id}&text=hello{
"ok": true,
"result": {
"message_id": 6,
"from": {
"id": 1010000036,
"is_bot": true,
"first_name": "chanshiyubot",
"username": "chanshiyu_bot"
},
"chat": {
"id": 98000006,
"first_name": "蝉",
"last_name": "时雨",
"type": "private"
},
"date": 1578035550,
"text": "text"
}
}<dependency>
<groupId>com.github.pengrad</groupId>
<artifactId>java-telegram-bot-api</artifactId>
<version>4.6.0</version>
</dependency>telegram-bot:
token: ${your_bot_token}@Slf4j
@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class TelegramBotService implements UpdatesListener {
/**
* token
*/
@Value("${telegram-bot.token}")
private String telegramBotToken;
/**
* bot
*/
private TelegramBot bot;
@Override
public int process(List<Update> updates) {
updates.forEach(update -> {
log.info("机器人收到消息 -> {}", update);
});
return UpdatesListener.CONFIRMED_UPDATES_ALL;
}
public void run() {
// Create your bot passing the token received from @BotFather
this.bot = new TelegramBot(this.telegramBotToken);
// Register for updates
this.bot.setUpdatesListener(this);
}
/**
* 发送消息
*
* @param type 消息类型
* @param chatId 会话ID
* @param text 消息内容
*/
public void sendMessage(Byte type, long chatId, String text) {
SendResponse response;
if (type == 1) {
// 图片
response = bot.execute(new SendPhoto(chatId, text));
} else {
// 文本
response = bot.execute(new SendMessage(chatId, text));
}
log.info("发送消息 -> {}", response);
}
public void close() {
this.bot.removeGetUpdatesListener();
}
}@Component
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class TelegramStartedBootstrap implements ApplicationListener<ContextRefreshedEvent> {
private final TelegramBotService telegramBotService;
@Override
public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
telegramBotService.run();
}
}