wechat spring boot starter
修复一些杂项问题
WeChat-bezogene Komponenten werden noch verbessert. Vielen Dank an JetBrains für die Anerkennung dieses Projekts: https://github.com/lcy19930619/wechat-spring-boot-starter
Wiki-Adresse: https://github.com/lcy19930619/wechat-spring-boot-starter/wiki
Einige der in WeChat-Dokumenten geschriebenen Dinge fühlen sich etwas chaotisch an, und viele Dinge müssen gefunden und durchsucht werden. Die Wiederverwendbarkeit des Codes von Baidu, csdn usw. ist nicht hoch, daher habe ich diese Komponente in der Hoffnung auf eine bessere Vielseitigkeit geschrieben .
Aktivieren Sie es über die Konfigurationsdatei. Nach dem Aktivieren werden die Informationen verschlüsselt und entschlüsselt. Sie müssen die Nachrichtenverschlüsselungs- und -entschlüsselungsmethode im WeChat-Hintergrund festlegen: Abgesicherter Modus
<dependencyManagement>
<dependencies>
<dependency>
<groupId>net.jlxxw</groupId>
<artifactId>wechat-spring-boot-starter</artifactId>
<version>${最新版本请查看仓库}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-event-netty-spring-boot-starter</ artifactId >
</ dependency >< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-event-web-spring-boot-starter</ artifactId >
</ dependency >Schritt:
@Component -Annotation hinzuzufügenDer Beispielcode lautet wie folgt:
import net . jlxxw . wechat . event . component . listener . AbstractWeChatMessageListener ;
import net . jlxxw . wechat . dto . message . AbstractWeChatMessage ;
import net . jlxxw . wechat . enums . WeChatMessageTypeEnum ;
import net . jlxxw . wechat . response . WeChatMessageResponse ;
import org . springframework . stereotype . Component ;
/**
* 用户发送消息监听器
* @author chunyang.leng
* @date 2021-12-18 6:19 下午
*/
@ Component
public class TextMessageListener extends AbstractWeChatMessageListener {
/**
* 支持的消息类型
*
* @return
*/
@ Override
public WeChatMessageTypeEnum supportMessageType () {
// 文本信息 WeChatMessageTypeEnum.TEXT
// 图片信息 WeChatMessageTypeEnum.IMAGE
// 语音信息 WeChatMessageTypeEnum.VOICE
// 视频信息 WeChatMessageTypeEnum.VIDEO
// 小视频信息 WeChatMessageTypeEnum.SHORT_VIDEO
// 地理位置信息 WeChatMessageTypeEnum.LOCATION
// 链接信息 WeChatMessageTypeEnum.LINK
// 更多类型，参考枚举 WeChatMessageTypeEnum
return WeChatMessageTypeEnum . TEXT ;
}
/**
* 处理微信消息 ,return null时，会转换为 "" 返回到微信服务器
*/
@ Override
public WeChatMessageResponse handler ( AbstractWeChatMessage abstractWeChatMessage ) {
// 类型转化参考 supportMessageType() 方法中枚举定义
TextMessage textMessage = ( TextMessage ) abstractWeChatMessage ;
// 用户发送的内容
String content = textMessage . getContent ();
// 用户openId
String fromUserName = textMessage . getFromUserName ();
// 返回图文信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildArticle();
// 返回图片信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildImage();
// 返回音乐信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildMusic();
// 返回文本信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildText();
// 返回视频信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildVideo();
// 返回音频信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildVoice();
return WeChatMessageResponse . buildText ( "回复用户一个文本信息" );
}
}Schritt:
@Component -Annotation hinzuzufügen. Der Beispielcode lautet wie folgt: import net . jlxxw . wechat . dto . message . event . SubscribeEventMessage ;
import net . jlxxw . wechat . event . component . listener . AbstractWeChatEventListener ;
import net . jlxxw . wechat . dto . message . AbstractWeChatMessage ;
import net . jlxxw . wechat . enums . WeChatEventTypeEnum ;
import net . jlxxw . wechat . response . WeChatMessageResponse ;
import org . junit . Assert ;
import org . springframework . stereotype . Component ;
/**
* 用户关注事件监听器
* @author chunyang.leng
* @date 2021-12-19 7:08 下午
*/
@ Component
public class SubscribeEventMessageListener extends AbstractWeChatEventListener {
/**
* 支持的事件类型
*/
@ Override
public WeChatEventTypeEnum supportEventType () {
// 文本信息 WeChatMessageTypeEnum.TEXT
// 图片信息 WeChatMessageTypeEnum.IMAGE
// 语音信息 WeChatMessageTypeEnum.VOICE
// 视频信息 WeChatMessageTypeEnum.VIDEO
// 小视频信息 WeChatMessageTypeEnum.SHORT_VIDEO
// 地理位置信息 WeChatMessageTypeEnum.LOCATION
// 链接信息 WeChatMessageTypeEnum.LINK
// 更多类型，参考枚举 WeChatMessageTypeEnum
return WeChatEventTypeEnum . SUBSCRIBE ;
}
/**
* 处理微信消息 ,return null时，会转换为 "" 返回到微信服务器
*/
@ Override
public WeChatMessageResponse handler ( AbstractWeChatMessage abstractWeChatMessage ) {
Assert . assertNotNull ( "接收到的数据不应为空" , abstractWeChatMessage );
// 类型转化参考 supportMessageType() 方法中枚举定义
SubscribeEventMessage subscribeEventMessage = ( SubscribeEventMessage ) abstractWeChatMessage ;
// 用户关注 event key
String eventKey = subscribeEventMessage . getEventKey ();
// 用户openId
String fromUserName = subscribeEventMessage . getFromUserName ();
// 返回图文信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildArticle();
// 返回图片信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildImage();
// 返回音乐信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildMusic();
// 返回文本信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildText();
// 返回视频信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildVideo();
// 返回音频信息，具体内容补充方法参数即可
// WeChatMessageResponse.buildVoice();
return WeChatMessageResponse . buildText ( supportEventType (). getDescription () + " done" );
}
}Anwendbare Szenarien:
< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-function-spring-boot-starter</ artifactId >
</ dependency > import net . jlxxw . wechat . enums . LanguageEnum ;
import net . jlxxw . wechat . function . WeChatFunctionAutoConfiguration ;
import net . jlxxw . wechat . response . user . SubscriptionResponse ;
import org . springframework . beans . factory . annotation . Autowired ;
import org . springframework . beans . factory . annotation . Value ;
import org . springframework . boot . test . context . SpringBootTest ;
import org . springframework . test . context . ActiveProfiles ;
import org . springframework . test . context . TestPropertySource ;
import org . springframework . util . CollectionUtils ;
import org . springframework . stereotype . Component ;
@ Component
public class UserManagerTest {
@ Autowired
public UserManager userManager ;
public void getUserInfoTest ( String openId ) {
SubscriptionResponse userInfo = userManager . getUserInfo ( openId , LanguageEnum . ZH_CN );
Assert . assertTrue ( "查询到的用户信息不应为空" , Objects . nonNull ( userInfo ));
}
}< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-repository-mysql-spring-boot-starter</ artifactId >
</ dependency >Schritt:
import net . jlxxw . wechat . repository . token . WeChatTokenRepository ;
import org . springframework . stereotype . Component ;
/**
* @author chunyang.leng
* @date 2024-01-12 17:45
*/
@ Component
public class MyTokenRepositoryImpl implements WeChatTokenRepository {
/**
* 保存token
*
* @param token
*/
@ Override
public void save ( String token ) {
}
/**
* 获取保存在本地的token
*
* @return 保存在本地的token
*/
@ Override
public String get () {
return null ;
}
}< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-security-spring-boot-starter</ artifactId >
</ dependency >< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-simple-schedule-spring-boot-starter</ artifactId >
</ dependency >< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-common</ artifactId >
</ dependency >< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-event</ artifactId >
</ dependency >< dependency >
< groupId >net.jlxxw</ groupId >
< artifactId >wechat-event</ artifactId >
</ dependency > 1. WeChat-Event-Netty-Spring-Boot-Starter wird beim Systemstart initialisiert und startet den WeChatEventNettyServer.javanetty-Server
2. Wenn die WeChat-Anfrage eintrifft, beginnt WeChatChannelMessageHandler.java zu arbeiten. 3. Wenn das Sicherheitsunterstützungsmodul wechat-security-spring-boot-starter hinzugefügt wird, wird die Anforderungs-IP über SecurityHandler.java überprüft. 4. Die Anforderung wird an EventBus weitergeleitet .java 5. Parsen WeChat fordert Daten an, sucht und registriert sie entsprechend dem Ereignis und MsgType im IOC-Container für den Listener (dh den von Ihnen selbst geschriebenen Business-Listener).
6. Rufen Sie die Handler-Methode des Listeners auf, um zugehörige Dienste auszuführen
7. Daten an den WeChat-Server zurücksenden
1. wechat-event-web-spring-boot-starter wird beim Systemstart initialisiert und registriert WeChatMessageController als Programmeingang. 2. WeChat-Datenanfragen werden an WeChatMessageController gesendet und die Whitelist-Authentifizierung wird durchgeführt. 3. Leiten Sie die Anfrage an EventBus weiter
4. Analysieren Sie die WeChat-Anforderungsdaten und suchen Sie den im IOC-Container registrierten Listener gemäß Ereignis und MsgType (dh den von Ihnen selbst geschriebenen Business-Listener).
5. Rufen Sie die Handler-Methode des Listeners auf, um zugehörige Dienste auszuführen
6. Daten an den WeChat-Server zurücksenden
wechat :
# 需要替换为真实数据
app-id : wx97562dcec7e78aca
# 需要替换为真实数据
secret : 995bc3e1c1e0d30884f3d2e1f033eced
verify-token : mytoken123456
# 需要替换为真实数据
encoding-aes-key : 9hFP1tCoPIRB8rFk4ukaYn6bw1Gbxs53yIGVplNsxxx
event :
server :
# 引入 event-netty 使用，与 event-web 互斥
netty :
codec : cipher_text
port : 9999
log :
enable : true
level : debug
verify-token-url : /verify
core-controller-url : /we
# 引入 event-web 使用，与 event-netty 互斥
web :
core-controller-url : /we
codec : cipher_text
# 引入 wechat-repository-mysql-spring-boot-starter 使用
repository :
mysql :
enable-auto-create-js-api-table : true
enable-auto-create-token-table : true
