Menu
🌜
🌞
- 1. 框架介绍
- 2. 注册中心
- 3. 服务Provider
- 4. 网关&监控
- 5. 服务资源监控
- 6. 集群接口文档
- 7. Hello World
- 8. 集成Java
- 9. 进阶指南
- 10. 领域驱动设计
- 11. 事件总线
- 12. 更多
- 13.1 好文章集合
##### Java服务的资源监控#
##### .Net服务的资源监控(运行时长、内存、CPU、硬盘、访问量)#
##### 从网关(.NET5.0实现)访问Java服务#
#### 8.1.4 java端功能开发实例代码#
package anno.componentservice;
import anno.componentservice.Models.UserInfo;
import anno.componentservice.events.UserEvent;
import anno.configuration.AnnoTheadPool;
import anno.entities.SysMember;
import anno.repository.SysMemberMapper;
import anno.thrift.annotation.AnnoInfo;
import anno.thrift.module.ActionResult;
import anno.thrift.module.BaseModule;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.HashMap;
@Service
//@Scope("prototype")
public class UserInfoModule extends BaseModule {
@Autowired
private ApplicationEventPublisher publisher;
@Autowired
private SysMemberMapper sysMemberMapper;
@AnnoInfo(desc = "用户信息")
public ActionResult<Object> GetUserInfo(GetUserInfoRequestDto queryInput){
UserInfo userinfo=new UserInfo();
userinfo.setAge(18);
userinfo.setName("Tom");
HashMap<String,Object> output=new HashMap<String, Object>();
output.put("key1","value1");
output.put("key2","value2");
for(HashMap.Entry<String,Object> kv:output.entrySet()){
output.put(kv.getKey(),kv.getValue());
}
HashMap<String,Object> outputData=new HashMap<String, Object>();
outputData.put("queryInput",queryInput);
outputData.put("userinfo",userinfo);
String msg= "this message from Java Server UserInfoModule.";
return new ActionResult<Object>(true, outputData, output, msg);
}
@AnnoInfo(desc = "你好世界")
public ActionResult<Object> HelloWorld(@AnnoInfo(desc = "名称",name = "name",required = false,defaultValue = "Anno Default Value") String anno){
String greetings="Hello "+anno+" I am Anno!";
return new ActionResult<>(true,greetings);
}
public void PublishMsg(String name){
if(name==null){
name="Anno";
}
UserEvent uv=new UserEvent();
uv.setId(10010);
uv.setName(name);
/
线程池方式发布事件
/
AnnoTheadPool.getPool().execute(()->{
publisher.publishEvent(uv);
});
/
发布事件异步 创建线程
/
// new Thread(()->{
// publisher.publishEvent(uv);
// }).start();
/*
直接发布事件 同步
*/
// publisher.publishEvent(uv);
}
@AnnoInfo(desc = "根据ID获取用户信息")
public ActionResult<SysMember> GetUserAutowired(long id) {
SysMember member=sysMemberMapper.selectById(id);
return new ActionResult<>(true,member);
}
}
Edit this page
Previous
« 7.3 插件ApiDoc文档
Next
9.1 进阶指南 »
文档
社区
更多
Copyright © 2022 Anno.

