wechat spring boot starter
修复一些杂项问题
WeChat 관련 구성 요소는 계속 개선되고 있습니다. 프로젝트 주소: https://github.com/lcy19930619/wechat-spring-boot-starter
위키 주소: https://github.com/lcy19930619/wechat-spring-boot-starter/wiki
WeChat 문서에 작성된 내용 중 일부가 다소 지저분하게 느껴지고, Baidu, csdn 등의 코드 재사용성이 높지 않아 더 나은 다양성을 바라며 이 구성 요소를 작성했습니다. .
구성 파일을 통해 켜면 정보가 암호화되고 해독됩니다. WeChat 백그라운드에서 메시지 암호화 및 암호 해독 방법을 설정해야 합니다---기본 구성---서버 구성: 안전 모드
<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 >단계:
@Component 주석을 추가하려면 Spring에 맡기세요.샘플 코드는 다음과 같습니다.
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 ( "回复用户一个文本信息" );
}
}단계:
@Component 주석을 추가하려면 Spring에 맡기십시오. 샘플 코드는 다음과 같습니다. 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" );
}
}적용 가능한 시나리오:
< 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 >단계:
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. 시스템이 시작되고 WeChatEventNettyServer.javanetty 서버가 시작되면 wechat-event-netty-spring-boot-starter가 초기화됩니다.
2. WeChat 요청이 도착하면 WeChatChannelMessageHandler.java가 작동하기 시작합니다. 3. 보안 지원 모듈 wechat-security-spring-boot-starter가 추가되면 SecurityHandler.java를 통해 요청 IP를 확인합니다. 4. 요청이 EventBus로 전달됩니다. .java 5. WeChat이 요청한 데이터를 구문 분석하고 이벤트 및 MsgType에 따라 ioc 컨테이너에 검색하여 리스너(즉, 직접 작성한 비즈니스 리스너)에게 등록합니다.
6. 리스너의 핸들러 메소드를 호출하여 관련 서비스를 수행합니다.
7. WeChat 서버에 데이터 반환
1. 시스템이 시작되면서 wechat-event-web-spring-boot-starter가 초기화되고, WeChatMessageController를 프로그램 입구로 등록합니다. 2. WeChat 데이터 요청이 WeChatMessageController로 전송되고 화이트리스트 인증이 수행됩니다. 3. 요청을 EventBus로 전달
4. WeChat 요청 데이터를 분석하여 이벤트 및 MsgType에 따라 ioc 컨테이너에 등록된 리스너(즉, 직접 작성한 비즈니스 리스너)를 찾습니다.
5. 리스너의 핸들러 메소드를 호출하여 관련 서비스를 수행합니다.
6. WeChat 서버에 데이터 반환
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
