• Discord OAuth2授权以及机器人监听群事件

    下面文章讲解获取OAuth2授权整个流程，创建机器人，使用机器人监听工会（工会就是创建的服务器）成员变化等等，对接国外的都是需要VPN的哦，对接的时候记得提前准备。

    创建应用

    点击 此页面添加应用,，创建完成以后会生成应用名称，公钥，客户id等等，这些我们可以保存下来。这些应用会自动和我们的工会关联的。

    创建机器人

    在下面页面创建一个机器人，机器人会会生成自己的token，这个一定要保存好，注意机器人安全。


    配置OAuth2

    页面创建我们的OAuth2，重定向URL需要配置前端页面的URL，因为获取用户token需要重定向到前端页面，这个地方我们自定义配置即可，授权我们可以访问用户的一些功能权限。

    将机器人加入我们的工会

     创建工会（服务器）直接在discord聊天页面创建就好了，这个就不多说了，那么我们如何将我们的机器人拉入到我们的服务器呢？

    选择OAuth2，选择bot，勾选机器人的工会权限，然后下面会生成一个链接。

    打开链接会出现下图内容，我们将我们的机器人加入到我们自己的服务器即可。 

    我们通过上面的步骤成功的创建了我们的应用、工会和机器人，下面我们将介绍如何使用OAuth2相关功能以及操作机器人。

    OAuth2功能实现

    

    com.discord4j
    discord4j-core
    3.2.1



    net.dv8tion
    JDA
    5.0.0-beta.12

    根据配置的OAuth2页面生成相关的链接，用户点击授权以后回调到前端页面，页面会带有code以及state参数，code我们用来换取token，state授权页面我们传什么参数过去会给我们带回来的一个参数，授权类似与下面的地址。

    https://discord.com/oauth2/authorize?client_id=1215207180614246411&state=%E9%9A%8F%E6%9C%BA%E5%8F%82%E6%95%B0&response_type=code&redirect_uri=http%3A%2F%2F9cxuu6.natappfree.cc%2Fdiscord%2FgetDiscordByCode&scope=identify+guilds+email+guilds.join+connections+guilds.members.read
     

    根据token交互用户数据

    拿到token以后我们可以查询用户的信息，用户工会情况等等。

    1. package com.odcchina.server.api;
    2.  
    3. import com.odcchina.common.config.BaseComponent;
    4. import com.odcchina.server.dto.DiscordDto;
    5. import com.odcchina.server.service.DiscordService;
    6. import com.odcchina.server.service.GuildEvent;
    7. import io.swagger.annotations.Api;
    8. import io.swagger.annotations.ApiOperation;
    9. import lombok.extern.slf4j.Slf4j;
    10. import net.dv8tion.jda.api.JDABuilder;
    11. import net.dv8tion.jda.api.requests.GatewayIntent;
    12. import org.springframework.beans.factory.annotation.Autowired;
    13. import org.springframework.transaction.annotation.Isolation;
    14. import org.springframework.transaction.annotation.Transactional;
    15. import org.springframework.web.bind.annotation.GetMapping;
    16. import org.springframework.web.bind.annotation.RequestMapping;
    17. import org.springframework.web.bind.annotation.RestController;
    18.  
    19. import java.util.HashMap;
    20. import java.util.Map;
    21.  
    22. @Slf4j
    23. @RestController
    24. @RequestMapping("/discord")
    25. @Api(tags = "discord服务")
    26. @Transactional(isolation = Isolation.READ_COMMITTED)
    27. public class DiscordController extends BaseComponent {
    28.  
    29.     @Autowired
    30.     private DiscordService discordService;
    31.  
    32.     /**
    33.      * 授权回调code
    34.      * @param code
    35.      * @return
    36.      */
    37.     @GetMapping("getDiscordByCode")
    38.     @ApiOperation("获取discord的Code")
    39.     public Map getTuiteCode(String code) {
    40.         Map map = new HashMap<>();
    41.         //根据code换取token
    42.         DiscordDto discordDto = discordService.getToken(code,null);
    43.         map.put("code", code);
    44.         map.put("access_token", discordDto.getAccessToken());
    45.         map.put("refresh_token", discordDto.getRefreshToken());
    46.         return map;
    47.     }
    48.  
    49.     @GetMapping("findLaborUnionList")
    50.     @ApiOperation("查询我的工会列表")
    51.     public Map findLaborUnionList(String token) {
    52.         Map map = new HashMap<>();
    53.         try {
    54.             discordService.findLaborUnionList(token);
    55.         } catch (Exception e) {
    56.             throw new RuntimeException(e);
    57.         }
    58.         return map;
    59.     }
    60.  
    61.     @GetMapping("findUserLaborUnion")
    62.     @ApiOperation("查询用户是否存在工会里面")
    63.     public Map findUserLaborUnion(String token,String guildId) {
    64.         Map map = new HashMap<>();
    65.         try {
    66.             discordService.findUserLaborUnion(token,guildId);
    67.         } catch (Exception e) {
    68.             throw new RuntimeException(e);
    69.         }
    70.         return map;
    71.     }
    72.  
    73.     @GetMapping("findUser")
    74.     @ApiOperation("查询用户信息")
    75.     public Map findUser(String token) {
    76.         Map map = new HashMap<>();
    77.         try {
    78.             discordService.findUser(token);
    79.         } catch (Exception e) {
    80.             throw new RuntimeException(e);
    81.         }
    82.         return map;
    83.     }
    84.     
    85. }
    86.  
    1. package com.odcchina.server.service;
    2.  
    3. import com.alibaba.fastjson.JSON;
    4. import com.alibaba.fastjson.JSONArray;
    5. import com.alibaba.fastjson.JSONObject;
    6. import com.github.scribejava.apis.DiscordApi;
    7. import com.odcchina.server.config.DiscordConfig;
    8. import com.odcchina.server.dto.DiscordDto;
    9. import com.odcchina.server.dto.DiscordlaborUnionDto;
    10. import com.odcchina.server.dto.UserDto;
    11. import lombok.extern.slf4j.Slf4j;
    12. import net.dv8tion.jda.api.JDA;
    13. import net.dv8tion.jda.api.JDABuilder;
    14. import org.apache.commons.lang3.StringUtils;
    15. import org.apache.http.HttpEntity;
    16. import org.apache.http.client.ClientProtocolException;
    17. import org.apache.http.client.entity.UrlEncodedFormEntity;
    18. import org.apache.http.client.methods.CloseableHttpResponse;
    19. import org.apache.http.client.methods.HttpGet;
    20. import org.apache.http.client.methods.HttpPost;
    21. import org.apache.http.impl.client.CloseableHttpClient;
    22. import org.apache.http.impl.client.HttpClientBuilder;
    23. import org.apache.http.impl.client.HttpClients;
    24. import org.apache.http.message.BasicNameValuePair;
    25. import org.apache.http.util.EntityUtils;
    26. import org.springframework.stereotype.Service;
    27.  
    28. import java.io.*;
    29. import java.net.HttpURLConnection;
    30. import java.net.URL;
    31. import java.util.*;
    32.  
    33. @Slf4j
    34. @Service
    35. public class DiscordService {
    36.  
    37.     /**
    38.      * form表单提交
    39.      * @param url
    40.      * @param map
    41.      * @return
    42.      */
    43.     public DiscordDto doPostForm(String url, Map map) {
    44.         String strResult = "";
    45.         CloseableHttpClient client = HttpClients.createDefault();
    46.         HttpPost httpPost = new HttpPost(url);
    47.         httpPost.setHeader("Content-Type","application/x-www-form-urlencoded;charset=UTF-8");
    48.         List paramPairs = new ArrayList<>();
    49.         Set keySet = map.keySet();
    50.         for (String key : keySet) {
    51.             Object val = map.get(key);
    52.             paramPairs.add(new BasicNameValuePair(key, val.toString()));
    53.         }
    54.         UrlEncodedFormEntity entity;
    55.         try {
    56.             // 4. 将参数设置到entity对象中
    57.             entity = new UrlEncodedFormEntity(paramPairs, "UTF-8");
    58.             // 5. 将entity对象设置到httppost对象中
    59.             httpPost.setEntity(entity);
    60.             // 6. 发送请求并回去响应
    61.             CloseableHttpResponse resp = client.execute(httpPost);
    62.             try {
    63.                 HttpEntity respEntity = resp.getEntity();
    64.                 strResult = EntityUtils.toString(respEntity, "UTF-8");
    65.                 JSONObject json = JSON.parseObject(strResult.toString());
    66.                 Object access_token = json.get("access_token");
    67.                 Object refresh_token = json.get("refresh_token");
    68.                 Object token_type = json.get("token_type");
    69.                 Object expires_in = json.get("expires_in");
    70.                 if(access_token == null || refresh_token == null){
    71.                     return null;
    72.                 }
    73.                 DiscordDto discordDto = new DiscordDto();
    74.                 discordDto.setAccessToken(access_token.toString());
    75.                 discordDto.setRefreshToken(refresh_token.toString());
    76.                 discordDto.setTokenType(token_type.toString());
    77.                 discordDto.setExpiresIn(Integer.parseInt(expires_in.toString()));
    78.                 return discordDto;
    79.             } finally {
    80.                 resp.close();
    81.             }
    82.         } catch (ClientProtocolException e) {
    83.             e.printStackTrace();
    84.         } catch (UnsupportedEncodingException e) {
    85.             e.printStackTrace();
    86.         } catch (IOException e) {
    87.             e.printStackTrace();
    88.         } finally {
    89.             // 10. 关闭连接，释放资源
    90.             try {
    91.                 client.close();
    92.             } catch (Exception e) {
    93.                 e.printStackTrace();
    94.             }
    95.         }
    96.         return null;
    97.     }
    98.  
    99.     /**
    100.      * 根据code换取token
    101.      *
    102.      * @param code
    103.      * @return
    104.      */
    105.     public DiscordDto getToken(String code,String refreshToken) {
    106.         try {
    107.             Map formData = new HashMap<>();
    108.             if(!StringUtils.isBlank(code)){
    109.                 formData.put("grant_type", "authorization_code");
    110.                 formData.put("code", code);
    111.             }
    112.             if(!StringUtils.isBlank(refreshToken)){
    113.                 formData.put("refresh_token", refreshToken);
    114.                 formData.put("grant_type", "refresh_token");
    115.             }
    116.             //TODO 重定向配置的URL,一定要和重定向里面的地址保持一致
    117.             formData.put("redirect_uri", 重定向配置的地址URL");
    118.             formData.put("client_id", DiscordConfig.CLIENT_ID);
    119.             formData.put("client_secret", DiscordConfig.CLIENT_SECRET);
    120.             // 创建URL对象
    121.             DiscordDto discordDto = this.doPostForm("https://discord.com/api/oauth2/token",formData);
    122.             return discordDto;
    123.         } catch (Exception e) {
    124.             throw new RuntimeException(e);
    125.         }
    126.     }
    127.  
    128.     /**
    129.      * 获取用户的所有服务器
    130.      * @param token
    131.      * @return
    132.      */
    133.     public List findLaborUnionList(String token) {
    134.         try {
    135.             // 设置请求URL和Bearer Token
    136.             CloseableHttpClient httpClient = HttpClientBuilder.create().build();
    137.             HttpGet httpPost = new HttpGet("https://discord.com/api/v9/users/@me/guilds");
    138.             httpPost.setHeader("Content-Type", "application/json;charset=utf8");
    139.             httpPost.setHeader("Authorization", "Bearer " + token);
    140.             CloseableHttpResponse response = null;
    141.             // 由客户端执行(发送)Post请求
    142.             response = httpClient.execute(httpPost);
    143.             // 从响应模型中获取响应实体
    144.             HttpEntity responseEntity = response.getEntity();
    145.             if (response.getStatusLine().getStatusCode() == 200 && responseEntity != null) {
    146.                 String responseJson = EntityUtils.toString(responseEntity);
    147.                 JSONArray jsonArray = JSON.parseArray(responseJson);
    148.                 List jsonArrayToStringList = JSONObject.parseArray(jsonArray.toJSONString(),DiscordlaborUnionDto.class);
    149.                 return jsonArrayToStringList;
    150.             }
    151.         } catch (Exception e) {
    152.             e.printStackTrace();
    153.         }
    154.         return null;
    155.     }
    156.  
    157.     public Boolean findUserLaborUnion(String token, String guildId) {
    158.         try {
    159.             // 设置请求URL和Bearer Token
    160.             CloseableHttpClient httpClient = HttpClientBuilder.create().build();
    161.             HttpGet httpPost = new HttpGet("https://discord.com/api/v9/users/@me/guilds/" + guildId+"/member");
    162.             httpPost.setHeader("Content-Type", "application/json;charset=utf8");
    163.             httpPost.setHeader("Authorization", "Bearer " + token);
    164.             CloseableHttpResponse response = null;
    165.             // 由客户端执行(发送)Post请求
    166.             response = httpClient.execute(httpPost);
    167.             // 从响应模型中获取响应实体
    168.             HttpEntity responseEntity = response.getEntity();
    169.             if (response.getStatusLine().getStatusCode() == 200 && responseEntity != null) {
    170.                 String responseJson = EntityUtils.toString(responseEntity);
    171.                 JSONObject jsonArray = JSON.parseObject(responseJson);
    172.                 if(jsonArray.get("user") != null){
    173.                     return true;
    174.                 }
    175.             }
    176.         } catch (Exception e) {
    177.             e.printStackTrace();
    178.         }
    179.         return false;
    180.     }
    181.  
    182.     /**
    183.      * 查询用户信息
    184.      * @param token
    185.      * @return
    186.      */
    187.     public UserDto findUser(String token) {
    188.         try {
    189.             // 设置请求URL和Bearer Token
    190.             CloseableHttpClient httpClient = HttpClientBuilder.create().build();
    191.             HttpGet httpPost = new HttpGet("https://discord.com/api/v9/users/@me");
    192.             httpPost.setHeader("Content-Type", "application/json;charset=utf8");
    193.             httpPost.setHeader("Authorization", "Bearer " + token);
    194.             CloseableHttpResponse response = null;
    195.             // 由客户端执行(发送)Post请求
    196.             response = httpClient.execute(httpPost);
    197.             // 从响应模型中获取响应实体
    198.             HttpEntity responseEntity = response.getEntity();
    199.             if (response.getStatusLine().getStatusCode() == 200 && responseEntity != null) {
    200.                 String responseJson = EntityUtils.toString(responseEntity);
    201.                 JSONObject jsonArray = JSON.parseObject(responseJson);
    202.                 UserDto userDto = JSON.toJavaObject(jsonArray, UserDto.class);
    203.                 return userDto;
    204.             }
    205.         } catch (Exception e) {
    206.             e.printStackTrace();
    207.         }
    208.         return null;
    209.     }
    210.  
    211. }
    1. package com.odcchina.server.dto;
    2.  
    3. import lombok.Data;
    4. import lombok.experimental.Accessors;
    5.  
    6. @Data
    7. @Accessors(chain = true)
    8. public class DiscordDto {
    9.  
    10.     /**
    11.      * 访问令牌
    12.      */
    13.     private String accessToken;
    14.  
    15.     /**
    16.      * 刷新令牌
    17.      */
    18.     private String refreshToken;
    19.  
    20.     /**
    21.      * 认证方式 Bearer
    22.      */
    23.     private String tokenType;
    24.  
    25.     /**
    26.      * 过期时间 （秒）
    27.      */
    28.     private Integer expiresIn;
    29.  
    30. }
    1. package com.odcchina.server.dto;
    2.  
    3. import lombok.Data;
    4. import lombok.experimental.Accessors;
    5.  
    6. /**
    7.  * 获取工会列表
    8.  */
    9. @Data
    10. @Accessors(chain = true)
    11. public class DiscordlaborUnionDto {
    12.  
    13.  
    14.     /**
    15.      * 工会ID
    16.      */
    17.     public String id;
    18.  
    19.  
    20.     /**
    21.      * 工会名称
    22.      */
    23.     public String name;
    24.  
    25. }
    1. package com.odcchina.server.dto;
    2.  
    3. import lombok.Data;
    4. import lombok.experimental.Accessors;
    5.  
    6. @Data
    7. @Accessors(chain = true)
    8. public class DiscordUserDto {
    9.  
    10.     /**
    11.      * 服务器ID
    12.      */
    13.     private String guildId;
    14.  
    15.     /**
    16.      * 服务器名称
    17.      */
    18.     private String guildName;
    19.  
    20.     /**
    21.      * 用户ID
    22.      */
    23.     private String userId;
    24.  
    25.     /**
    26.      * 用户名称
    27.      */
    28.     private String userName;
    29.  
    30. }
    1. package com.odcchina.server.config;
    2.  
    3. /**
    4.  * Discord相关配置
    5.  */
    6. public class DiscordConfig {
    7.  
    8.     /**
    9.      * 客户id和客户私钥
    10.      */
    11.     public static final String CLIENT_ID = "111111";
    12.     public static final String CLIENT_SECRET = "nL8gLAmZEFZYtQQ2mqE3tEYWC111111";
    13.     public static final String PUBLIC_CLIENT_SECRET = "feca6db06a1af3c5ebff8fb3710213b86651f6401623d103a5111111";
    14.  
    15.     public static final String TOKEN_ENDPOINT = "https://discord.com/api/oauth2/token";
    16. }

    使用机器人监听工会会员变动情况

    工会会员新加入，退出等情况监听，前期我们需要开启下面这些功能，不然机器人无法监听：

    1.     @GetMapping("botMonitor")
    2.     @ApiOperation("开启机器人监听服务")
    3.     public Map botMonitor() {
    4.         //启动机器人，监听成员事件
    5.         try {
    6.             //这里是机器人的token的，注意下
    7.             String botToken = "1111.Gh00hD.1111";
    8.             JDABuilder builder = JDABuilder.createDefault(botToken);
    9.             //添加事件监听器
    10.             builder.addEventListeners(new GuildEvent());
    11.             //builder.useSharding(int shardId, int shardTotal)
    12.             //工会成员 GUILD_MEMBERS TODO 这个地方在机器人里面有个选项需要开启，不然无法调用
    13.             builder.enableIntents(GatewayIntent.GUILD_MEMBERS);
    14.             builder.build();
    15.         } catch (Exception e) {
    16.             e.printStackTrace();
    17.         }

    当我们启动以后我们的机器人就会在线，由于我没有启动监听，所以我们的机器人在离线中的：

    1. package com.odcchina.server.service;
    2.  
    3. import com.odcchina.server.dto.DiscordUserDto;
    4. import net.dv8tion.jda.api.entities.Guild;
    5. import net.dv8tion.jda.api.entities.User;
    6. import net.dv8tion.jda.api.events.guild.GuildLeaveEvent;
    7. import net.dv8tion.jda.api.events.guild.invite.GuildInviteCreateEvent;
    8. import net.dv8tion.jda.api.events.guild.invite.GuildInviteDeleteEvent;
    9. import net.dv8tion.jda.api.events.guild.member.GuildMemberJoinEvent;
    10. import net.dv8tion.jda.api.events.guild.member.GuildMemberRemoveEvent;
    11. import net.dv8tion.jda.api.events.guild.member.GuildMemberRoleAddEvent;
    12. import net.dv8tion.jda.api.events.guild.member.GuildMemberRoleRemoveEvent;
    13. import net.dv8tion.jda.api.hooks.ListenerAdapter;
    14. import javax.annotation.Nonnull;
    15.  
    16. public class GuildEvent extends ListenerAdapter {
    17.  
    18.     @Override
    19.     public void onGuildInviteCreate(@Nonnull GuildInviteCreateEvent event) {
    20.         //一个邀请被创建了
    21.     }
    22.  
    23.     @Override
    24.     public void onGuildInviteDelete(@Nonnull GuildInviteDeleteEvent event) {
    25.         //一个邀请被删除了
    26.     }
    27.  
    28.     @Override
    29.     public void onGuildMemberJoin(@Nonnull GuildMemberJoinEvent event) {
    30.         //有新成员进入公会
    31.         Guild guild = event.getGuild();
    32.         User user = event.getUser();
    33.         DiscordUserDto discordUserDto = new DiscordUserDto();
    34.         discordUserDto.setGuildId(guild.getId());
    35.         discordUserDto.setGuildName(guild.getName());
    36.         discordUserDto.setUserId(user.getId());
    37.         discordUserDto.setUserName(user.getName());
    38.     }
    39.  
    40.     @Override
    41.     public void onGuildLeave(@Nonnull GuildLeaveEvent event) {
    42.         //有老成员离开公会
    43.     }
    44.  
    45.     @Override
    46.     public void onGuildMemberRemove(@Nonnull GuildMemberRemoveEvent event) {
    47.         //有成员被移除公会
    48.     }
    49.  
    50.     @Override
    51.     public void onGuildMemberRoleAdd(@Nonnull GuildMemberRoleAddEvent event) {
    52.         //公会成员添加角色
    53.     }
    54.  
    55.     @Override
    56.     public void onGuildMemberRoleRemove(@Nonnull GuildMemberRoleRemoveEvent event) {
    57.         //公会成员移除角色
    58.     }
    59. }

    机器人其他功能调用，比如查询邀请信息，查询邀请我的频道会员

    https://discord.com/api/v9/channels/工会ID/invites

    关于其他机器人功能实现可以参考下面的文档，大佬写的很详细，点这里 

  • 相关阅读:
    30分钟使用百度EasyDL实现烟雾检测
    Zookeeper客户端命令、JAVA API、监听原理、写数据原理以及案例
    鸿蒙Harmony应用开发—ArkTS声明式开发（触摸事件）
    数据结构与算法 | 哈希表（Hash Table）
    软考-系统架构-2023-反思
    想在golang里用好泛型还挺难的
    【华为OD机试真题 JS】数组拼接
    java计算机毕业设计学科竞赛管理系统源码+数据库+系统+lw文档+部署
    台式电脑的IP地址在哪里？解密台式电脑网络连接的秘密！
    nodejs--开发自己的项目——5.2——个人中心模块——重置密码——设置的url:/my/updatepwd——post请求
  • 原文地址：https://blog.csdn.net/qq_38935605/article/details/136619200