最近公司有个新的需求,写了一个接口,想要把服务暴露出去,但是这个服务所在的进程是非web项目,(可以理解成schedule/batch等进程项目),所以没有tomcat等容器,而且只有这一个服务,无论是加dubbo服务还是加tomcat等容器都显得复杂了。那么应该如何将服务暴露出去?
经过网上搜索后,最终解决问题,记录在此。
为了快速搭建,使用springboot来搭建项目:
项目结构如图:
首先需要创建一个接口,服务的提供者和服务的调用方都依赖这个模块。
package com.xiazhi.spring.service.api; import com.sun.istack.internal.NotNull; import com.sun.istack.internal.Nullable; /** * @author 赵帅 * @date 2020/6/8 */ public interface IUserService { /** * 获取姓名 * @return 姓名 */ String getName(); /** * 根据姓名获取年龄 * @param name 姓名 * @return 年龄 */ @NotNull Integer getAge(@Nullable String name); }
然后在service模块中,实现接口作为服务的提供方,需要依赖的jar包有:
<dependencies> <dependency> <groupId>com.xiazhi</groupId> <artifactId>spring-service-api</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <exclusions> <exclusion> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-tomcat</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>servlet-api</artifactId> <version>2.5</version> </dependency> </dependencies>
配置文件需要加上:
spring.main.web-application-type=none
实现接口:
package com.xiazhi.spring.service.impl; import com.sun.istack.internal.NotNull; import com.sun.istack.internal.Nullable; import com.xiazhi.spring.service.api.IUserService; import org.springframework.stereotype.Service; /** * @author 赵帅 * @date 2020/6/8 */ @Service public class UserServiceImpl implements IUserService { @Override public String getName() { return "张一"; } @Override @NotNull public Integer getAge(@Nullable String name) { if ("".equals(name)) { return 10; } return 18; } }
暴露服务:
package com.xiazhi.spring.service.config; import com.sun.net.httpserver.HttpHandler; import com.xiazhi.spring.service.api.IUserService; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.task.TaskExecutor; import org.springframework.remoting.httpinvoker.SimpleHttpInvokerServiceExporter; import org.springframework.remoting.support.SimpleHttpServerFactoryBean; import java.util.HashMap; import java.util.Map; /** * @author 赵帅 * @date 2020/6/8 */ @Configuration public class HttpInvokerConfiguration { private final IUserService userService; private final TaskExecutor taskExecutor; public HttpInvokerConfiguration(IUserService userService, TaskExecutor taskExecutor) { this.userService = userService; this.taskExecutor = taskExecutor; } /** * 将IUserService服务暴露出去 */ @Bean public SimpleHttpInvokerServiceExporter serviceExporter() { SimpleHttpInvokerServiceExporter exporter = new SimpleHttpInvokerServiceExporter(); exporter.setService(userService); exporter.setServiceInterface(IUserService.class); return exporter; } /** * 为暴露的服务启用http服务 * @return httpServer工厂类 */ @Bean public SimpleHttpServerFactoryBean serverFactoryBean() { SimpleHttpServerFactoryBean factoryBean = new SimpleHttpServerFactoryBean(); Map<String, HttpHandler> map = new HashMap<>(2); factoryBean.setContexts(map); factoryBean.setPort(9999); factoryBean.setExecutor(taskExecutor); return factoryBean; } }
启动服务。
然后是服务的调用方,依赖有:
<dependencies> <dependency> <groupId>com.xiazhi</groupId> <artifactId>spring-service-api</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies>
配置文件:
package com.xiazhi.spring.config; import com.xiazhi.spring.service.api.IUserService; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean; /** * @author 赵帅 * @date 2020/6/8 */ @Configuration public class HttpServiceConfiguration { /** * 使用http代理工厂调用服务 * @return http代理工厂创建代理对象 */ @Bean public HttpInvokerProxyFactoryBean httpInvokerProxyFactoryBean() { HttpInvokerProxyFactoryBean factoryBean = new HttpInvokerProxyFactoryBean(); factoryBean.setServiceUrl("http://localhost:9999/userService"); factoryBean.setServiceInterface(IUserService.class); return factoryBean; } }
使用接口,调用方法:
package com.xiazhi.spring.controller; import com.xiazhi.spring.service.api.IUserService; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; /** * @author 赵帅 * @date 2020/6/8 */ @RestController public class UserController { private final IUserService userService; public UserController(IUserService userService) { this.userService = userService; } @GetMapping("/test") public String test() { String name = userService.getName(); Integer age = userService.getAge(null); System.out.println(String.format("姓名:[%s],age:[%s]", name, age)); return name; } }
运行,调用test路径测试调用结果。
项目完整结构:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。
更新日志
- 【雨果唱片】中国管弦乐《鹿回头》WAV
- APM亚流新世代《一起冒险》[FLAC/分轨][106.77MB]
- 崔健《飞狗》律冻文化[WAV+CUE][1.1G]
- 罗志祥《舞状元 (Explicit)》[320K/MP3][66.77MB]
- 尤雅.1997-幽雅精粹2CD【南方】【WAV+CUE】
- 张惠妹.2007-STAR(引进版)【EMI百代】【WAV+CUE】
- 群星.2008-LOVE情歌集VOL.8【正东】【WAV+CUE】
- 罗志祥《舞状元 (Explicit)》[FLAC/分轨][360.76MB]
- Tank《我不伟大,至少我能改变我。》[320K/MP3][160.41MB]
- Tank《我不伟大,至少我能改变我。》[FLAC/分轨][236.89MB]
- CD圣经推荐-夏韶声《谙2》SACD-ISO
- 钟镇涛-《百分百钟镇涛》首批限量版SACD-ISO
- 群星《继续微笑致敬许冠杰》[低速原抓WAV+CUE]
- 潘秀琼.2003-国语难忘金曲珍藏集【皇星全音】【WAV+CUE】
- 林东松.1997-2039玫瑰事件【宝丽金】【WAV+CUE】