wechat spring boot starter
修复一些杂项问题
Komponen terkait WeChat masih ditingkatkan. Terima kasih kepada JetBrains karena mengenali alamat proyek ini: https://github.com/lcy19930619/wechat-spring-boot-starter.
Alamat Wiki: https://github.com/lcy19930619/wechat-spring-boot-starter/wiki
Beberapa hal yang ditulis dalam dokumen WeChat terasa agak berantakan, dan banyak hal yang perlu ditemukan dan dicari. Penggunaan kembali kode Baidu, csdn, dll. tidak tinggi, jadi saya menulis komponen ini dengan harapan fleksibilitas yang lebih baik. .
Aktifkan melalui file konfigurasi. Setelah menyalakannya, informasi akan dienkripsi dan didekripsi. Anda perlu mengatur metode enkripsi dan dekripsi pesan di latar belakang WeChat---Konfigurasi Dasar---Konfigurasi Server sebagai: Mode Aman.
<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 >melangkah:
@ComponentContoh kodenya adalah sebagai berikut:
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 ( "回复用户一个文本信息" );
}
}melangkah:
@Component . Contoh kodenya adalah sebagai berikut: 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" );
}
}Skenario yang berlaku:
< 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 >melangkah:
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 diinisialisasi saat sistem dimulai dan memulai server WeChatEventNettyServer.javanetty
2. Ketika permintaan WeChat tiba, WeChatChannelMessageHandler.java mulai bekerja 3. Jika modul dukungan keamanan wechat-security-spring-boot-starter ditambahkan, ip permintaan diperiksa melalui SecurityHandler.java 4. Permintaan diteruskan ke EventBus. java 5. Mengurai data permintaan WeChat, mencari dan mendaftarkannya di wadah ioc sesuai dengan acara dan MsgType ke pendengar (yaitu, pendengar bisnis yang Anda tulis sendiri)
6. Panggil metode pengendali pendengar untuk melakukan layanan terkait
7. Kembalikan data ke server WeChat
1. wechat-event-web-spring-boot-starter diinisialisasi saat sistem dimulai, dan mendaftarkan WeChatMessageController sebagai pintu masuk program. 2. Permintaan data WeChat dikirim ke WeChatMessageController, dan otentikasi daftar putih dilakukan. 3. Meneruskan permintaan ke EventBus
4. Parsing data permintaan WeChat, temukan pendengar yang terdaftar di wadah ioc sesuai dengan acara dan MsgType (yaitu, pendengar bisnis yang Anda tulis sendiri)
5. Panggil metode pengendali pendengar untuk melakukan layanan terkait
6. Kembalikan data ke server 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
