OPQ4J

介绍

OPQ/IOTQQ/IOTBot 的一个 Java/Kotlin 开发助手

使用说明

maven引入

<dependency>
  <groupId>io.github.leishui</groupId>
  <artifactId>OPQ4J</artifactId>
  <version>1.0.0</version>
</dependency>

gradle

implementation 'io.github.leishui:OPQ4J:1.0.0'

简单用例

Java

import core.Core;
import listener.OPQListener;
import org.jetbrains.annotations.NotNull;

public class JMain {
    public static void main(String[] args) {
        //服务器地址、端口、机器人QQ
        Core core = new Core("http://xxx.xxx.xxx.xxx", 2233, 1000000000);
        /*设置发送消息的最小间隔时间，默认为1000ms
        由于服务器响应速度等问题，间隔时间过小可能导致消息丢失*/
        //core.setDelay(500);
        //1.通过重写OPQListener中的方法进行监听
        //我只实现了部分消息监听  详见源码
        core.start(new OPQListener() {
            @Override
            public void onPrivateTextMsg(long toQQ, @NotNull String textContent) {
                super.onPrivateTextMsg(toQQ, textContent);
                /*
                Core提供了4个发送消息的方法,详见源码中的注释
                1.sendPrivateMsg
                2.sendGroupMsg
                3.sendGroupMsgWithAt
                4.sendMsg 通过路径和参数调用所有服务端的接口
                 */
                core.sendPrivateMsg(toQQ, textContent);
                //使用sendMsg方法时需要注意带'\'的需要将'\'转义，例如:
                //'\n'->'\\n'         '\"'->'\\\"'
                String nContent = "\\\"a\\nb\\n";
                core.postData("/v1/LuaApiCaller?qq=" + Core.Companion.getCurrentQQ() + "&funcname=SendMsg&timeout=10",
                        "{\"toUser\":" + toQQ + ",\"sendToType\":1,\"sendMsgType\":\"TextMsg\",\"content\":\"" + nContent + "\",\"groupid\":0,\"atUser\":0}");
            }
        });
        //2.可参考OPQListener通过继承OPQBaseListener实现自己的Listener进行监听
//        core.start(new OPQBaseListener(){
//            @Override
//            public void onPrivateMsg(@NotNull String rawMsg) {
//                System.out.println(rawMsg);
//            }
//        });
    }
}

kotlin

import core.Core
import listener.OPQListener

fun main() {
    //服务器地址、端口、机器人QQ
    //val core = Core("http://xxx.xxx.xxx.xxx", 2233, 1000000000)
    val core = Core("http://xxx.xxx.xxx.xxx", 2233, 1000000000)
    /*设置发送消息的最小间隔时间，默认为1000ms
        由于服务器响应速度等问题，间隔时间过小可能导致消息丢失*/
    //core.setDelay(500);
    //1.通过重写OPQListener中的方法进行监听
    //我只实现了部分消息监听 详见源码[Event]{"CurrentPacket":{"WebConnId":"","Data":{"EventMsg":{"Content":"某人进群事件","MsgSeq":20784,"FromUin":696922228,"MsgType":"ON_EVENT_GROUP_JOIN","ToUin":2056378490,"RedBaginfo":null},"EventName":"ON_EVENT_GROUP_JOIN","EventData":{"InviteUin":1223812424,"UserName":"1","UserID":136203345}}},"CurrentQQ":2056378490}
    core.start(object : OPQListener() {
        override fun onPrivateTextMsg(toQQ: Long, textContent: String) {
            super.onPrivateTextMsg(toQQ, textContent)
            /*
                Core提供了4个发送消息的方法,详见源码中的注释
                1.sendPrivateMsg
                2.sendGroupMsg
                3.sendGroupMsgWithAt
                4.sendMsg 通过路径和参数调用所有服务端的接口
                 */
            core.sendPrivateMsg(toQQ, textContent)
            //使用sendMsg方法时需要注意带'\'的需要将'\'转义，例如:
            //'\n'->'\\n'         '\"'->'\\\"'
            val nContent = "\\\"a\\nb\\n"
            core.postData("/v1/LuaApiCaller?qq=${Core.currentQQ}&funcname=SendMsg&timeout=10",
                    """{"toUser":$toQQ,"sendToType":1,"sendMsgType":"TextMsg","content":"$nContent","groupid":0,"atUser":0}""")
        }
    })
    //2.可参考OPQListener通过继承OPQBaseListener实现自己的Listener进行监听
//    core.start(object : OPQBaseListener() {
//        override fun onPrivateMsg(rawMsg: String) {
//            println(rawMsg)
//        }
//    })
}