AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

个人微信api接口java调用源代码

2024-06-21 89
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 个人微信api接口java调用源代码

个人微信api接口，微信sdk

1、微信好友收发消息

/**
* 给微信好友发消息
* @author wechatno:tangjinjinwx
* @blog http://www.wlkankan.cn
*/
@Async
public void handleMsg(ChannelHandlerContext ctx, TransportMessage vo, String contentJsonStr) {
try {
log.debug(contentJsonStr);
TalkToFriendTaskMessage.Builder bd = TalkToFriendTaskMessage.newBuilder();
JsonFormat.parser().merge(contentJsonStr, bd);
TalkToFriendTaskMessage req = bd.build();
// 消息记录数据库
asyncTaskService.savePcMessage(req);
// 将消息转发送给手机客户端
asyncTaskService.msgSend2Phone(ctx, req.getWeChatId(), EnumMsgType.TalkToFriendTask, vo, req);
} catch (Exception e) {
    e.printStackTrace();
    MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
  }
}
 
 
/**
 * 微信好友发来聊天消息通知
 * @author wechatno:tangjinjinwx
     * @blog http://www.wlkankan.cn
 */
@Async
public void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {
  try {
    FriendTalkNoticeMessage req = vo.getContent().unpack(FriendTalkNoticeMessage.class);
    log.debug(JsonFormat.printer().print(req));
    
    log.debug(LocalDateTime.now()+" 微信好友发来聊天消息  对应的线程名: "+Thread.currentThread().getName());
      
        //拦截消息
    asyncTaskService.msgAopTask(ctx,req,vo.getAccessToken(), vo.getId());
    //消息转发到pc端
    asyncTaskService.msgSend2pc(req.getWeChatId(), EnumMsgType.FriendTalkNotice, req);
     
      // 告诉客户端消息已收到
      MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
      
      WxAccountInfo account = weChatAccountService.findWeChatAccountInfoByWeChatId(req.getWeChatId());
    //消息记录数据库
    if (null != account){
      asyncTaskService.saveMessage(account, req);
      }
     
  } catch (Exception e) {
    e.printStackTrace();
    MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam,vo.getId(), e.getMessage());
  }
}

2、触发手机推送微信好友列表及返回

/**
* 触发手机推送微信好友列表
* @author wechatno:tangjinjinwx
* @blog http://www.wlkankan.cn
*/
@Async
public void handleMsg(ChannelHandlerContext ctx,TransportMessage vo, String contentJsonStr) {
try {
log.debug(contentJsonStr);
TriggerFriendPushTaskMessage.Builder bd = TriggerFriendPushTaskMessage.newBuilder();
JsonFormat.parser().merge(contentJsonStr, bd);
TriggerFriendPushTaskMessage req = bd.build();
//TriggerFriendPushTaskMessage req = vo.getContent().unpack(TriggerFriendPushTaskMessage.class);
//将消息转发送给手机客户端
      asyncTaskService.msgSend2Phone(ctx, req.getWeChatId(), EnumMsgType.TriggerFriendPushTask, vo, req);
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
    }
}
 
 
/**
 * 微信好友列表消息推送
 * @author wechatno:tangjinjinwx
     * @blog http://www.wlkankan.cn
 */
@Async
public void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {
  try {
    FriendPushNoticeMessage req = vo.getContent().unpack(FriendPushNoticeMessage.class);
    log.debug(JsonFormat.printer().print(req));
    // 把消息转发给pc端
    asyncTaskService.msgSend2pc(req.getWeChatId(), EnumMsgType.FriendPushNotice, req);
     
    // 异步保存到数据库
    asyncTaskService.friendListSave(req);
     
    // 告诉客户端消息已收到
    MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
 
  } catch (Exception e) {
    e.printStackTrace();
    MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam, vo.getId(), Constant.ERROR_MSG_DECODFAIL);
  }
}

3、触发推送微信群聊列表及返回

/**
* 触发推送微信群聊列表
* @author wechatno:tangjinjinwx
* @blog http://www.wlkankan.cn
*/
@Async
public void handleMsg(ChannelHandlerContext ctx, TransportMessage vo, String contentJsonStr) {
try {
log.debug(contentJsonStr);
TriggerChatRoomPushTaskMessage.Builder bd = TriggerChatRoomPushTaskMessage.newBuilder();
JsonFormat.parser().merge(contentJsonStr, bd);
TriggerChatRoomPushTaskMessage req = bd.build();
// 将消息转发送给手机客户端
asyncTaskService.msgSend2Phone(ctx, req.getWeChatId(), EnumMsgType.TriggerChatroomPushTask, vo, req);
} catch (Exception e) {
e.printStackTrace();
MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
}
}
/**
 * 推送微信群聊列表
 * @author wechatno:tangjinjinwx
     * @blog http://www.wlkankan.cn
 */
@Async
public  void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {
    try {
      ChatRoomPushNoticeMessage req = vo.getContent().unpack(ChatRoomPushNoticeMessage.class);
      log.debug(JsonFormat.printer().print(req));
    
    asyncTaskService.msgSend2pc(req.getWeChatId(), EnumMsgType.ChatroomPushNotice, req);
     
    asyncTaskService.qunListSave(req);
      
    // 告诉客户端消息已收到
    MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam,vo.getId(), Constant.ERROR_MSG_DECODFAIL);
    }
}

4、推送微信朋友圈、发朋友圈

/**
* 触发推送朋友圈列表
* @author wechatno:tangjinjinwx
* startTime传秒
* @blog http://www.wlkankan.cn
*/
@Async
public void handleMsg(ChannelHandlerContext ctx, TransportMessage vo, String contentJsonStr) {
try {
log.debug(contentJsonStr);
TriggerCirclePushTaskMessage.Builder bd = TriggerCirclePushTaskMessage.newBuilder();
JsonFormat.parser().merge(contentJsonStr, bd);
TriggerCirclePushTaskMessage req = bd.build();
// TriggerCirclePushTaskMessage req =
// vo.getContent().unpack(TriggerCirclePushTaskMessage.class);
// 将消息转发送给手机客户端
asyncTaskService.msgSend2Phone(ctx, req.getWeChatId(), EnumMsgType.TriggerCirclePushTask, vo, req);
} catch (Exception e) {
e.printStackTrace();
MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
}
}
/**
 * 回传手机微信朋友圈数据
 * @author wechatno:tangjinjinwx
     * @blog http://www.wlkankan.cn
 */
@Async
public  void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {
    try {
      CirclePushNoticeMessage req = vo.getContent().unpack(CirclePushNoticeMessage.class);
      log.debug(JsonFormat.printer().print(req));
      //把消息转发给pc端
    asyncTaskService.msgSend2pc(req.getWeChatId(), EnumMsgType.CirclePushNotice, req);
    
    //保存朋友圈信息
    asyncTaskService.asyncSaveCircleMsg(req, circleService, weChatContactService);
    
      //告诉客户端消息已收到
    MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam,vo.getId(), Constant.ERROR_MSG_DECODFAIL);
    }
}
 
/**
 * 发微信朋友圈
 * @author wechatno:tangjinjinwx
 * @blog http://www.wlkankan.cn
 */
@Async
public  void handleMsg(ChannelHandlerContext ctx,TransportMessage vo, String contentJsonStr) {
    try {
      log.debug(contentJsonStr);
      PostSNSNewsTaskMessage.Builder bd = PostSNSNewsTaskMessage.newBuilder();
      JsonFormat.parser().merge(contentJsonStr, bd);
    PostSNSNewsTaskMessage req = bd.build();
      //PostSNSNewsTaskMessage req = vo.getContent().unpack(PostSNSNewsTaskMessage.class);
        
      asyncTaskService.msgSend2Phone(ctx, req.getWeChatId(), EnumMsgType.PostSNSNewsTask, vo, req);
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
    }
}

5、加好友及通过好友请求

/** 
 * 微信自动添加好友
 * @author wechatno:tangjinjinwx
     * @blog http://www.wlkankan.cn
 */
@Async
public  void handleMsg(ChannelHandlerContext ctx ,TransportMessage vo, String contentJsonStr) {
    try {
      log.debug(contentJsonStr);
      FriendAddTaskSetting  req =  JSON.parseObject(contentJsonStr,FriendAddTaskSetting.class);
      if(null != req){
        String resp ="fail";
         
        resp = friendAddTaskService.savePcTask(req);
         
        //3、告诉PC客户端消息已收到
        MessageUtil.sendCustomJsonMsg(ctx, "AutoFriendAddTaskResp", resp);
        
      } 
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendJsonErrMsg(ctx, EnumErrorCode.InvalidParam, Constant.ERROR_MSG_DECODFAIL);
    }
}
 
 
    /**
 * 微信新增好友通知
 * @author wechatno:tangjinjinwx
     * @blog http://www.wlkankan.cn
 */
@Async
public  void handleMsg(ChannelHandlerContext ctx, TransportMessage vo) {
    try {
      FriendAddNoticeMessage req = vo.getContent().unpack(FriendAddNoticeMessage.class);
       
    //把消息转发给pc端
    asyncTaskService.msgSend2pc(req.getWeChatId(), EnumMsgType.FriendAddNotice, req);
    
    //保存新增好友
    asyncTaskService.saveFriendAddContactinfo(req);
    
    //告诉客户端消息已收到
    MessageUtil.sendMsg(ctx, EnumMsgType.MsgReceivedAck, vo.getAccessToken(), vo.getId(), null);
      
     
    } catch (Exception e) {
        e.printStackTrace();
        MessageUtil.sendErrMsg(ctx, EnumErrorCode.InvalidParam,vo.getId(), Constant.ERROR_MSG_DECODFAIL);
    }
}


文章标签：
API
Java
开发工具
关键词：
Java接口
Java API
API java
API接口
微信源代码
weixin_836869520
目录
相关文章
2的n次方_
|
5天前
|
Java
Java——抽象类和接口
抽象类是一种不能被实例化的类，至少包含一个抽象方法（无实现体的方法），常用于定义一组相关类的共同特征，并强制子类实现特定方法。抽象方法不能被 `static` 或 `final` 修饰，且必须被重写。 接口则是一个完全抽象的类，用于规范类的行为。接口使用 `interface` 关键字定义，不能实例化，并且类与接口之间是实现关系。 内部类是在一个类内定义的类，分为成员内部类、静态内部类、局部内部类和匿名内部类。成员内部类可被修饰符修饰，静态内部类只能访问外部类的静态成员，局部内部类定义在方法内，匿名内部类则隐藏了名字，直接通过 `new` 关键字定义并实现接口或继承类。
2的n次方_
12 5
Java——抽象类和接口
智物科技库
|
9天前
|
Java API C++
Java 8 Stream Api 中的 peek 操作
本文介绍了Java中`Stream`的`peek`操作，该操作通过`Consumer<T>`函数消费流中的每个元素，但不改变元素类型。文章详细解释了`Consumer<T>`接口及其使用场景，并通过示例代码展示了`peek`操作的应用。此外，还对比了`peek`与`map`的区别，帮助读者更好地理解这两种操作的不同用途。作者为码农小胖哥，原文发布于稀土掘金。
智物科技库
29 9
Java 8 Stream Api 中的 peek 操作
2的n次方_
|
5天前
|
Java
Java——接口的使用实例
Comparable接口用于自定义类的对象比较。通过实现此接口并重写`compareTo`方法，可以定义自定义类型的比较规则。 接下来介绍了Comparator接口，它提供了一种更灵活的比较方式。通过实现Comparator接口并重写`compare`方法，可以根据不同属性定义不同的比较规则。例如，定义一个`BrandComparator`类来比较汽车的品牌。 最后，介绍了Cloneable接口，用于实现对象的克隆。实现该接口并重写`clone`方法后，可以创建对象的浅拷贝或深拷贝。浅拷贝仅复制对象本身，深拷贝则会递归复制所有成员变量。
2的n次方_
13 4
Java——接口的使用实例
蓝易云
|
11天前
|
Java 数据库连接 数据库
Java服务提供接口（SPI）的设计与应用剖析
Java SPI提供了一种优雅的服务扩展和动态加载机制，使得Java应用程序可以轻松地扩展功能和替换组件。通过合理的设计与应用，SPI可以大大增强Java应用的灵活性和可扩展性。
蓝易云
43 18
1941623231718325
|
13天前
|
安全 Java API
【性能与安全的双重飞跃】JDK 22外部函数与内存API：JNI的继任者，引领Java新潮流！
【9月更文挑战第7天】JDK 22外部函数与内存API的发布，标志着Java在性能与安全性方面实现了双重飞跃。作为JNI的继任者，这一新特性不仅简化了Java与本地代码的交互过程，还提升了程序的性能和安全性。我们有理由相信，在外部函数与内存API的引领下，Java将开启一个全新的编程时代，为开发者们带来更加高效、更加安全的编程体验。让我们共同期待Java在未来的辉煌成就！
1941623231718325
42 11
1941623231718325
|
14天前
|
安全 Java API
【本地与Java无缝对接】JDK 22外部函数和内存API：JNI终结者，性能与安全双提升！
【9月更文挑战第6天】JDK 22的外部函数和内存API无疑是Java编程语言发展史上的一个重要里程碑。它不仅解决了JNI的诸多局限和挑战，还为Java与本地代码的互操作提供了更加高效、安全和简洁的解决方案。随着FFM API的逐渐成熟和完善，我们有理由相信，Java将在更多领域展现出其强大的生命力和竞争力。让我们共同期待Java编程新纪元的到来！
1941623231718325
38 11
1941623231718325
|
11天前
|
监控 Java 大数据
【Java内存管理新突破】JDK 22：细粒度内存管理API，精准控制每一块内存！
【9月更文挑战第9天】虽然目前JDK 22的确切内容尚未公布，但我们可以根据Java语言的发展趋势和社区的需求，预测细粒度内存管理API可能成为未来Java内存管理领域的新突破。这套API将为开发者提供前所未有的内存控制能力，助力Java应用在更多领域发挥更大作用。我们期待JDK 22的发布，期待Java语言在内存管理领域的持续创新和发展。
1941623231718325
37 7
1941623231718325
|
13天前
|
Java API 数据处理
【Java的SIMD革命】JDK 22向量API：释放硬件潜能，让Java应用性能飙升！
【9月更文挑战第7天】 JDK 22向量API的发布标志着Java编程语言在SIMD技术领域的重大突破。这一新特性不仅释放了现代硬件的潜能，更让Java应用性能实现了飙升。我们有理由相信，在未来的发展中，Java将继续引领编程语言的潮流，为开发者们带来更加高效、更加强大的编程体验。让我们共同期待Java在SIMD技术的推动下开启一个全新的性能提升时代！
1941623231718325
52 9
java的细水长流
|
9天前
|
Java 开发者
Java的接口详解
Java接口是编程中的一种重要特性，用于定义方法签名而不提供具体实现，作为类之间的契约，使不同类能以统一方式交互。接口使用`interface`关键字定义，可包含方法声明和常量。类通过`implements`关键字实现接口，并可同时实现多个接口，解决多重继承问题。接口中的方法默认为抽象方法，变量默认为`public static final`。Java 8引入了默认方法和静态方法，增强接口功能。接口广泛应用于回调机制和多态性实现，有助于构建更灵活和可维护的代码结构。
java的细水长流
13 4
1941623231718325
|
14天前
|
Java API 开发者
【Java字节码操控新篇章】JDK 22类文件API预览：解锁Java底层的无限可能！
【9月更文挑战第6天】JDK 22的类文件API为Java开发者们打开了一扇通往Java底层世界的大门。通过这个API，我们可以更加深入地理解Java程序的工作原理，实现更加灵活和强大的功能。虽然目前它还处于预览版阶段，但我们已经可以预见其在未来Java开发中的重要地位。让我们共同期待Java字节码操控新篇章的到来！
1941623231718325
20 7

热门文章

最新文章

  • 1
    Java设计模式(一)----单例模式
  • 2
    Spring框架（SpringBoot）中redis报错（Could not get a resource from the pool、java.net.SocketTimeoutException）
  • 3
    java.io.IOException: Stream closed解决办法
  • 4
    SpringBoot运行出现 Lookup method resolution failed； nested exception is java.lang.IllegalStateException
  • 5
    JVM深入学习：Java解析Class文件过程解析
  • 6
    Java多线程之ReentrantReadWriteLock
  • 7
    Win11 系统Java17的安装教程：最新版JDK 17.07下载、安装、卸载详解
  • 8
    Redis反序列化错误Could not read JSON: Cannot construct instance of `java.util.ArrayList$SubList`
  • 9
    Java读取XML与xls文件
  • 10
    java反序列化时的类加载
  • 1
    企业微信应用结合Cpolar内网穿透实现固定域名验证回调本地接口服务
    129
  • 2
    微信小程序开发工具的使用，各个配置文件详解，小程序开发快速入门（二）
    374
  • 3
    微信小程序开发工具的使用，各个配置文件详解，小程序开发快速入门（一）
    179
  • 4
    轻松学会微信小程序开发（一）
    182
  • 5
    使用阿里云短信+微信短链接跳转微信小程序
    304
  • 6
    微信小程序开发1
    121
  • 7
    【Python+微信】【企业微信开发入坑指北】4. 企业微信接入GPT，只需一个URL，自动获取文章总结
    109
  • 8
    【Python+微信】【企业微信开发入坑指北】3. 如何利用企业微信API给微信群推送消息
    208
  • 9
    【Python+微信】【企业微信开发入坑指北】2. 如何利用企业微信API主动给用户发应用消息
    173
  • 10
    【Python+微信】【企业微信开发入坑指北】1. 数据链路打通：接收用户消息处理并回复
    77

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Boot2.0实战Redis分布式缓存
  • CUDA MATH API
  • API PLAYBOOK

    • 相关实验场景

    更多
  • 基于ECS搭建Java Web开发环境
  • 使用Aliyun Java Intializr进行项目开发
  • 搭建Java Web开发环境
  • 部署基于Dragonwell的Java运行环境
  • 阿里云平台上进行Java程序的编译与运行
  • RocketMQ中使用Java客户端发送消息和消费的应用
    • 下一篇
    通义千问API入门教程