代码拉取完成，页面将自动刷新
请等待上传到仓库
暂未上传，敬请期待
(注意：目前仅支持最多无参接收或者一参接收，暂不支持多个参数接收消息)
使用@SakaSService 既可以将此对象注入至Spring容器
使用@SakaSubscribe即可声明某方法为接收方法
| 参数名称 | 说明 | 默认值 | 备注 |
|---|---|---|---|
| debug | 是否为调试模式 | false | 调试模式在使用中会打印日志 |
| order | 设置优先级顺序 | 5 | 数字越小，优先级越高,越先被执行 |
如下定义了三种基本的接收器
/**
* 实现一个接收消息
*
* <p>使用@SakaService注入到Spring容器
*
* <p>使用@SakaSubscribe标注这是一个接收器
*
* @author tao
*/
@SakaService
public class BaseService {
/** 自动注入对象测试 */
@Autowired SpeakService speakService;
/** 不接受参数 */
@SakaSubscribe
public void sendEmpty() {
speakService.speak();
System.out.println("exec sendEmpty ");
}
/** 接受一个参数 */
@SakaSubscribe
public void sendString(String message) {
speakService.speak();
System.out.println("exec sendString = " + message);
}
/** 接受一个参数自定义的参数类型 */
@SakaSubscribe
public void sendClassObject(Message message) {
speakService.speak();
System.out.println("exec sendClassObject = " + message.getName());
}
}
Saka在应用启动的时候向Spring的Context中注入ISakaClient,在SpringBoot项目中可使用以下代码自动的注入Bean对象。
@RestController
public class TestController {
/** 自动注入SakaClient */
@Autowired
SakaSendClient sakaSendClient;
}
在需要发送消息的地方，注入SakaClient对象后，使用send()或者send(Object)方法发送消息.
@RestController
public class TestController {
/** 自动注入SakaClient */
@Autowired SakaSendClient sakaSendClient;
/**
* 尝试发送一个字符串消息
*
* @param name
* @return
* @throws Exception
*/
@GetMapping("/string/{name}")
public String sendString(@PathVariable("name") String name) throws Exception {
sakaSendClient.send(name);
return name;
}
/**
* 尝试发送自定义类型消息
*
* @param message
* @return
* @throws Exception
*/
@GetMapping("/message/{message}")
public String sendMessage(@PathVariable("message") String message) throws Exception {
Message messageObject = new Message().setName(message).setAge(12);
sakaSendClient.send(messageObject);
return messageObject.getName();
}
/**
* 尝试发送空消息
*
* @return
* @throws Exception
*/
@GetMapping("/empty")
public String sendEmpty() throws Exception {
sakaSendClient.send();
return "success";
}
}
可以使用注解@SakaSubscribe注解参数debug配置是否输入打印日志，默认是不打印日志。
//Saka注册接收器日志
Saka ------> Add a methods execCommand(1) to Saka
Saka ------> Add a methods sendClassObject(1) to Saka
Saka ------> Add a methods printMessage(0) to Saka
Saka ------> Add a methods speak(0) to Saka
//Saka发送消息
Saka ------> Send data to testMethodes1 successfully
Saka ------> Saka has successfully sent 1 times data.
Saka ------> Saka has successfully sent 1 times data.
Saka ------> Saka has successfully sent 1 times data.
在通过注解@SakaSubscribe设置Subscribe的同同时，您可以为其设置优先级order，如果不设置默认值为OrderConstance.ORDER_NORMALE(5)，数字越小，优先级越高,越先被执行。如下所示
@SakaSubscribe(debug = true,order = OrderConstance.ORDER_NORMALE)
public void printMessage() {}
/** 接受参数一个参数 */
@SakaSubscribe(debug = true,order = OrderConstance.ORDER_HIGHT)
public void execCommand(String message) {}
/** 接受一个参数自定义的参数类型 */
@SakaSubscribe(order = OrderConstance.ORDER_LOWWER)
public void sendClassObject(Message message) {}
同时,考虑到性能，顺序执行Subscribe是默认关闭状态的，您可以通过application配置文件配置启用此功能
saka.sequence-execute=true
saka:
sequence-execute: true
在一些情况下您可以设置listener来实现Subscribe的执行状况监听,您只需要在Spring容器中注入监听对象即可，此Bean要求继承HandleSubscribeListener接口。
比如:
@Bean
public HandleSubscribeListener handleSubscribeListener(){
return new HandleSubscribeListener() {
//TODO 返回执行结果
@Override
public void onSuccess(MetaMethod metaMethod, Object resultObject) {
log.info("Subscribe监听器接收到执行了方法 = {} ",metaMethod.getMethod().getName());
}
@Override
public boolean onError(Throwable t) {
log.error("Subscribe监听器接收执行错误的通知,错误信息 = {}",t);
return true;
}
};
}
public void onSuccess(MetaMethod, Object )方法，其中MetaMethod表示当前执行的对象,resultObject表示执行的结果对象public boolean onError(Throwable) 您可以返回一个布尔类型的数据表示是否继续执行剩余的Subscribe，其中Throwable表示出现的异常信息在使用的过程中,可以通过配置动态的关闭Saka,重新启动应用，可以看到以下提示则说明关闭成功。
Saka ------> Don't open the Saka, please check the configuration information
saka.enable= false
saka:
enable: false
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型
马建仓 AI 助手
