From fed590cdc62d508629ca32ba064554c418b94536 Mon Sep 17 00:00:00 2001 From: chandler <1915724901@qq.com> Date: Mon, 30 Sep 2024 23:22:55 +0800 Subject: [PATCH] =?UTF-8?q?feat(0):=20[java]-[wcferry-mvn]-=E6=9E=B6?= =?UTF-8?q?=E6=9E=84=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iamteer/BussinessContext.java | 17 -- .../iamteer/config/WechatConfiguration.java | 94 ++++++++++ .../WechatSocketClient.java} | 12 +- .../java/com/iamteer/runner/WechatRunner.java | 105 ----------- .../iamteer/service/impl/TestServiceImpl.java | 16 +- .../utils/SpringContextHolderUtil.java | 173 ------------------ 6 files changed, 109 insertions(+), 308 deletions(-) delete mode 100644 clients/java/wcferry-mvn/src/main/java/com/iamteer/BussinessContext.java create mode 100644 clients/java/wcferry-mvn/src/main/java/com/iamteer/config/WechatConfiguration.java rename clients/java/wcferry-mvn/src/main/java/com/iamteer/{Client.java => handle/WechatSocketClient.java} (98%) delete mode 100644 clients/java/wcferry-mvn/src/main/java/com/iamteer/runner/WechatRunner.java delete mode 100644 clients/java/wcferry-mvn/src/main/java/com/iamteer/utils/SpringContextHolderUtil.java diff --git a/clients/java/wcferry-mvn/src/main/java/com/iamteer/BussinessContext.java b/clients/java/wcferry-mvn/src/main/java/com/iamteer/BussinessContext.java deleted file mode 100644 index 93f3673..0000000 --- a/clients/java/wcferry-mvn/src/main/java/com/iamteer/BussinessContext.java +++ /dev/null @@ -1,17 +0,0 @@ -package com.iamteer; - -import org.springframework.core.annotation.Order; -import org.springframework.stereotype.Component; - -import lombok.Data; -import lombok.extern.slf4j.Slf4j; - -@Slf4j -@Component -@Data -@Order(100) -public class BussinessContext { - - private Client client; - -} diff --git a/clients/java/wcferry-mvn/src/main/java/com/iamteer/config/WechatConfiguration.java b/clients/java/wcferry-mvn/src/main/java/com/iamteer/config/WechatConfiguration.java new file mode 100644 index 0000000..4784430 --- /dev/null +++ b/clients/java/wcferry-mvn/src/main/java/com/iamteer/config/WechatConfiguration.java @@ -0,0 +1,94 @@ +package com.iamteer.config; + +import javax.annotation.Resource; + +import com.iamteer.handle.WechatSocketClient; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import lombok.extern.slf4j.Slf4j; + +/** + * 配置类-注入微信客户端 + * + * @author chandler + * @date 2024-09-30 12:21 + */ +@Slf4j +@Configuration +public class WechatConfiguration { + + @Resource + private WcferryProperties properties; + + @Bean + public WechatSocketClient client() { + log.debug("测试：端口：{}，地址：{}", properties.getSocketPort(), properties.getDllPath()); + // 连接远程 RPC + // Client client = new Client("127.0.0.1", 10086); + + // 本地启动 RPC + // Client client = new Client(); // 默认 10086 端口 + // Client client = new Client(10088,true); // 也可以指定端口 + WechatSocketClient wechatSocketClient = new WechatSocketClient(properties.getSocketPort(), properties.getDllPath()); + + // 是否已登录 + // log.info("isLogin: {}", client.isLogin()); + + // 登录账号 wxid + // log.info("wxid: {}", client.getSelfWxid()); + + // 消息类型 + // log.info("message types: {}", client.getMsgTypes()); + + // 所有联系人（包括群聊、公众号、好友……） + // client.printContacts(client.getContacts()); + + // 获取数据库 + log.info("dbs: {}", wechatSocketClient.getDbNames()); + + // 获取数据库下的表 + String db = "MicroMsg.db"; + // log.info("tables in {}: {}", db, client.getDbTables(db)); + + // 发送文本消息，aters 是要 @ 的 wxid，多个用逗号分隔；消息里@的数量要与aters里的数量对应 + // client.sendText("Hello", "filehelper", ""); + // client.sendText("Hello @某人1 @某人2", "xxxxxxxx@chatroom", "wxid_xxxxxxxxxxxxx1,wxid_xxxxxxxxxxxxx2"); + + // 发送图片消息，图片必须要存在 + // client.sendImage("C:\\Projs\\WeChatFerry\\TEQuant.jpeg", "filehelper"); + + // 发送文件消息，文件必须要存在 + // client.sendFile("C:\\Projs\\WeChatFerry\\README.MD", "filehelper"); + + String xml = + "叮当药房，24小时服务，28分钟送药到家！叮当快药首家承诺范围内28分钟送药到家！叮当快药核心区域内7*24小时全天候服务，送药上门！叮当快药官网为您提供快捷便利，正品低价，安全放心的购药、送药服务体验。view330https://mp.weixin.qq.com/mp/waerrpage?appid=wxc2edadc87077fa2a&type=upgrade&upgradetype=3#wechat_redirect7f6f49d301ebf47100199b8a4fcf4de4gh_c2b88a38c424@app叮当快药 药店送药到家夜间买药0jpgda0e08f5c7259d03da150d5e7ca6d9503057020100044b30490201000204e4c0232702032f4ef20204a6bace6f02046401f62d042430326337303430352d333734332d343362652d623335322d6233333566623266376334620204012400030201000405004c5376000db26456caf243fbd4efb99058a01d660db26456caf243fbd4efb99058a01d66161558100100pages/index/index.htmlgh_c2b88a38c424@appwxc2edadc87077fa2a1972http://wx.qlogo.cn/mmhead/Q3auHgzwzM4727n0NQ0ZIPQPlfp15m1WLsnrXbo1kLhFGcolgLyc0A/9601_wxc2edadc87077fa2a_29177e9a9b918cb9e75964f80bb8f32e_1677849476_0wxid_eob5qfcrv4zd2201"; + // client.sendXml("filehelper", xml, "", 0x21); + + // 发送表情消息，gif 必须要存在 + // client.sendEmotion("C:\\Projs\\WeChatFerry\\emo.gif", "filehelper"); + + // 接收消息，并调用 printWxMsg 处理 + wechatSocketClient.enableRecvMsg(100); + Thread thread = new Thread(new Runnable() { + public void run() { + while (wechatSocketClient.getIsReceivingMsg()) { + wechatSocketClient.printWxMsg(wechatSocketClient.getMsg()); + } + } + }); + thread.start(); + // client.diableRecvMsg(); // 需要停止时调用 + + wechatSocketClient.keepRunning(); + + new Thread(new Runnable() { + public void run() { + wechatSocketClient.keepRunning(); + } + }).start(); + + return wechatSocketClient; + } + +} diff --git a/clients/java/wcferry-mvn/src/main/java/com/iamteer/Client.java b/clients/java/wcferry-mvn/src/main/java/com/iamteer/handle/WechatSocketClient.java similarity index 98% rename from clients/java/wcferry-mvn/src/main/java/com/iamteer/Client.java rename to clients/java/wcferry-mvn/src/main/java/com/iamteer/handle/WechatSocketClient.java index 039aaf0..f0693b1 100644 --- a/clients/java/wcferry-mvn/src/main/java/com/iamteer/Client.java +++ b/clients/java/wcferry-mvn/src/main/java/com/iamteer/handle/WechatSocketClient.java @@ -1,4 +1,4 @@ -package com.iamteer; +package com.iamteer.handle; import java.nio.ByteBuffer; import java.util.Arrays; @@ -34,9 +34,9 @@ import io.sisu.nng.pair.Pair1Socket; import lombok.extern.slf4j.Slf4j; @Slf4j -public class Client { +public class WechatSocketClient { - private static final Logger logger = LoggerFactory.getLogger(Client.class); + private static final Logger logger = LoggerFactory.getLogger(WechatSocketClient.class); private static final int BUFFER_SIZE = 16 * 1024 * 1024; // 16M private Socket cmdSocket = null; private Socket msgSocket = null; @@ -52,15 +52,15 @@ public class Client { private int port; private String dllPath; - public Client() { + public WechatSocketClient() { this(DEFAULT_HOST, PORT, false, DEFAULT_DLL_PATH); } - public Client(int port, String dllPath) { + public WechatSocketClient(int port, String dllPath) { this(DEFAULT_HOST, port, false, dllPath); } - public Client(String host, int port, boolean debug, String dllPath) { + public WechatSocketClient(String host, int port, boolean debug, String dllPath) { this.host = host; this.port = port; this.dllPath = dllPath; diff --git a/clients/java/wcferry-mvn/src/main/java/com/iamteer/runner/WechatRunner.java b/clients/java/wcferry-mvn/src/main/java/com/iamteer/runner/WechatRunner.java deleted file mode 100644 index b806d76..0000000 --- a/clients/java/wcferry-mvn/src/main/java/com/iamteer/runner/WechatRunner.java +++ /dev/null @@ -1,105 +0,0 @@ -package com.iamteer.runner; - -import javax.annotation.Resource; - -import org.springframework.boot.ApplicationArguments; -import org.springframework.boot.ApplicationRunner; -import org.springframework.core.annotation.Order; -import org.springframework.stereotype.Component; - -import com.iamteer.BussinessContext; -import com.iamteer.Client; -import com.iamteer.config.WcferryProperties; - -import lombok.extern.slf4j.Slf4j; - -/** - * 启动回调-调用微信 - * - * @author chandler - * @date 2024-09-21 12:21 - */ -@Slf4j -@Component -@Order(101) -public class WechatRunner implements ApplicationRunner { - - @Resource - private WcferryProperties properties; - - @Resource - private BussinessContext bussinessContext; - - public WechatRunner(BussinessContext bussinessContext) { - this.bussinessContext = bussinessContext; - } - - @Override - public void run(ApplicationArguments args) throws Exception { - System.out.println(">>>服务启动第一个开始执行的任务<<<<"); - runWechat(); - } - - private void runWechat() { - log.debug("测试：端口：{}，地址：{}", properties.getSocketPort(), properties.getDllPath()); - // 连接远程 RPC - // Client client = new Client("127.0.0.1", 10086); - - // 本地启动 RPC - // Client client = new Client(); // 默认 10086 端口 - // Client client = new Client(10088,true); // 也可以指定端口 - Client client = new Client(properties.getSocketPort(), properties.getDllPath()); - bussinessContext.setClient(client); // 默认 10086 端口 - - // 是否已登录 - // log.info("isLogin: {}", client.isLogin()); - - // 登录账号 wxid - // log.info("wxid: {}", client.getSelfWxid()); - - // 消息类型 - // log.info("message types: {}", client.getMsgTypes()); - - // 所有联系人（包括群聊、公众号、好友……） - // client.printContacts(client.getContacts()); - - // 获取数据库 - log.info("dbs: {}", client.getDbNames()); - - // 获取数据库下的表 - String db = "MicroMsg.db"; - // log.info("tables in {}: {}", db, client.getDbTables(db)); - - // 发送文本消息，aters 是要 @ 的 wxid，多个用逗号分隔；消息里@的数量要与aters里的数量对应 - // client.sendText("Hello", "filehelper", ""); - // client.sendText("Hello @某人1 @某人2", "xxxxxxxx@chatroom", "wxid_xxxxxxxxxxxxx1,wxid_xxxxxxxxxxxxx2"); - - // 发送图片消息，图片必须要存在 - // client.sendImage("C:\\Projs\\WeChatFerry\\TEQuant.jpeg", "filehelper"); - - // 发送文件消息，文件必须要存在 - // client.sendFile("C:\\Projs\\WeChatFerry\\README.MD", "filehelper"); - - String xml = - "叮当药房，24小时服务，28分钟送药到家！叮当快药首家承诺范围内28分钟送药到家！叮当快药核心区域内7*24小时全天候服务，送药上门！叮当快药官网为您提供快捷便利，正品低价，安全放心的购药、送药服务体验。view330https://mp.weixin.qq.com/mp/waerrpage?appid=wxc2edadc87077fa2a&type=upgrade&upgradetype=3#wechat_redirect7f6f49d301ebf47100199b8a4fcf4de4gh_c2b88a38c424@app叮当快药 药店送药到家夜间买药0jpgda0e08f5c7259d03da150d5e7ca6d9503057020100044b30490201000204e4c0232702032f4ef20204a6bace6f02046401f62d042430326337303430352d333734332d343362652d623335322d6233333566623266376334620204012400030201000405004c5376000db26456caf243fbd4efb99058a01d660db26456caf243fbd4efb99058a01d66161558100100pages/index/index.htmlgh_c2b88a38c424@appwxc2edadc87077fa2a1972http://wx.qlogo.cn/mmhead/Q3auHgzwzM4727n0NQ0ZIPQPlfp15m1WLsnrXbo1kLhFGcolgLyc0A/9601_wxc2edadc87077fa2a_29177e9a9b918cb9e75964f80bb8f32e_1677849476_0wxid_eob5qfcrv4zd2201"; - // client.sendXml("filehelper", xml, "", 0x21); - - // 发送表情消息，gif 必须要存在 - // client.sendEmotion("C:\\Projs\\WeChatFerry\\emo.gif", "filehelper"); - - // 接收消息，并调用 printWxMsg 处理 - client.enableRecvMsg(100); - Thread thread = new Thread(new Runnable() { - public void run() { - while (client.getIsReceivingMsg()) { - client.printWxMsg(client.getMsg()); - } - } - }); - thread.start(); - // client.diableRecvMsg(); // 需要停止时调用 - - client.keepRunning(); - } - -} diff --git a/clients/java/wcferry-mvn/src/main/java/com/iamteer/service/impl/TestServiceImpl.java b/clients/java/wcferry-mvn/src/main/java/com/iamteer/service/impl/TestServiceImpl.java index cb192ac..abc5fef 100644 --- a/clients/java/wcferry-mvn/src/main/java/com/iamteer/service/impl/TestServiceImpl.java +++ b/clients/java/wcferry-mvn/src/main/java/com/iamteer/service/impl/TestServiceImpl.java @@ -2,11 +2,12 @@ package com.iamteer.service.impl; import java.util.List; +import javax.annotation.Resource; + import org.springframework.stereotype.Service; -import com.iamteer.BussinessContext; +import com.iamteer.handle.WechatSocketClient; import com.iamteer.service.TestService; -import com.iamteer.utils.SpringContextHolderUtil; import lombok.extern.slf4j.Slf4j; @@ -20,16 +21,17 @@ import lombok.extern.slf4j.Slf4j; @Service public class TestServiceImpl implements TestService { + @Resource + private WechatSocketClient wechatSocketClient; + @Override public Boolean isLogin() { - BussinessContext bussinessContext = SpringContextHolderUtil.getBean(BussinessContext.class); - - boolean flag = bussinessContext.getClient().isLogin(); + boolean flag = wechatSocketClient.isLogin(); log.info("flag:{}", flag); - List list = bussinessContext.getClient().getDbNames(); + List list = wechatSocketClient.getDbNames(); log.info("list:{}", list); - return flag; + return false; } } diff --git a/clients/java/wcferry-mvn/src/main/java/com/iamteer/utils/SpringContextHolderUtil.java b/clients/java/wcferry-mvn/src/main/java/com/iamteer/utils/SpringContextHolderUtil.java deleted file mode 100644 index 5282285..0000000 --- a/clients/java/wcferry-mvn/src/main/java/com/iamteer/utils/SpringContextHolderUtil.java +++ /dev/null @@ -1,173 +0,0 @@ -package com.iamteer.utils; - -import java.util.Map; - -import org.springframework.beans.MutablePropertyValues; -import org.springframework.beans.factory.DisposableBean; -import org.springframework.beans.factory.support.DefaultListableBeanFactory; -import org.springframework.beans.factory.support.GenericBeanDefinition; -import org.springframework.context.ApplicationContext; -import org.springframework.context.ApplicationContextAware; -import org.springframework.context.ApplicationEvent; -import org.springframework.context.annotation.Lazy; -import org.springframework.stereotype.Service; - -import com.alibaba.fastjson2.JSON; -import com.alibaba.fastjson2.JSONObject; - -import lombok.SneakyThrows; -import lombok.extern.slf4j.Slf4j; - -/** - * Spring 工具类 - * - * @author chandler - * @date 2023-03-30 11:05:49 - */ -@Slf4j -@Service -@Lazy(false) -public class SpringContextHolderUtil implements ApplicationContextAware, DisposableBean { - - /** - * 上下文对象实例 - */ - private static ApplicationContext applicationContext = null; - - /** - * 获取applicationContext-取得存储在静态变量中的ApplicationContext. - */ - public static ApplicationContext getApplicationContext() { - checkApplicationContext(); - return applicationContext; - } - - /** - * 实现ApplicationContextAware接口, 注入Context到静态变量中. - */ - @Override - public void setApplicationContext(ApplicationContext applicationContext) { - SpringContextHolderUtil.applicationContext = applicationContext; - } - - /** - * 通过name获取Bean-从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型. - */ - @SuppressWarnings("unchecked") - public static T getBean(String name) { - checkApplicationContext(); - if (applicationContext.containsBean(name)) { - return (T)applicationContext.getBean(name); - } - return null; - } - - /** - * 通过class获取Bean-从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型. - */ - public static T getBean(Class requiredType) { - checkApplicationContext(); - return applicationContext.getBean(requiredType); - } - - /** - * 通过name,以及Clazz返回指定的Bean - */ - public static T getBean(String name, Class requiredType) { - return getApplicationContext().getBean(name, requiredType); - } - - /** - * 从静态变量ApplicationContext中取得Bean, 自动转型为所赋值对象的类型. - */ - public static T getBeanOfType(Class clazz) { - checkApplicationContext(); - return (T)applicationContext.getBeansOfType(clazz); - } - - /** - * 清除SpringContextHolder中的ApplicationContext为Null. - */ - public static void clearHolder() { - if (log.isDebugEnabled()) { - log.debug("清除SpringContextHolder中的ApplicationContext:" + applicationContext); - } - applicationContext = null; - } - - /** - * 发布事件 - * - * @param event - */ - public static void publishEvent(ApplicationEvent event) { - if (applicationContext == null) { - return; - } - applicationContext.publishEvent(event); - } - - /** - * 实现DisposableBean接口, 在Context关闭时清理静态变量. - */ - @Override - @SneakyThrows - public void destroy() { - SpringContextHolderUtil.clearHolder(); - } - - public static synchronized void registerSingletonBean(String beanName, Class clzz, Map original) { - checkApplicationContext(); - DefaultListableBeanFactory beanFactory = - (DefaultListableBeanFactory)SpringContextHolderUtil.getApplicationContext().getAutowireCapableBeanFactory(); - if (beanFactory.containsBean(beanName)) { - removeBean(beanName); - } - GenericBeanDefinition definition = new GenericBeanDefinition(); - // 类class - definition.setBeanClass(clzz); - // 属性赋值 - definition.setPropertyValues(new MutablePropertyValues(original)); - // 注册到spring上下文 - beanFactory.registerBeanDefinition(beanName, definition); - } - - public static synchronized void registerSingletonBean(String beanName, Object obj, Map original) { - checkApplicationContext(); - DefaultListableBeanFactory beanFactory = - (DefaultListableBeanFactory)SpringContextHolderUtil.getApplicationContext().getAutowireCapableBeanFactory(); - if (beanFactory.containsBean(beanName)) { - removeBean(beanName); - } - GenericBeanDefinition definition = new GenericBeanDefinition(); - // 类class - definition.setBeanClass(obj.getClass()); - // 属性赋值 - definition.setPropertyValues(new MutablePropertyValues(original)); - // 注册到spring上下文 - beanFactory.registerBeanDefinition(beanName, definition); - } - - public static synchronized void registerSingletonBean(String beanName, Object obj) { - registerSingletonBean(beanName, obj, JSONObject.parseObject(JSON.toJSONString(obj), Map.class)); - } - - /** - * 删除spring中管理的bean - * - * @param beanName - */ - public static void removeBean(String beanName) { - ApplicationContext ctx = SpringContextHolderUtil.getApplicationContext(); - DefaultListableBeanFactory acf = (DefaultListableBeanFactory)ctx.getAutowireCapableBeanFactory(); - if (acf.containsBean(beanName)) { - acf.removeBeanDefinition(beanName); - } - } - - private static void checkApplicationContext() { - if (applicationContext == null) { - throw new IllegalStateException("applicaitonContext未注入,请在applicationContext.xml中定义SpringContextUtil"); - } - } -}