- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本篇实现订单服务接受异步消息。
package concurrent.activeobject2;
import concurrent.future.Future;
/**
* @className: OrderService
* @description: 订单接口
* @date: 2022/5/4
* @author: cakin
*/
public interface OrderService {
/**
* 功能描述:根据订单编号查询订单明细,有入参也有返回值,但是返回值类型必须是 Future
*
* @param orderId 订单编号
* @return Future<String>
* @author cakin
* @date 2022/5/4
* @description: 因为方法的执行是在其他线程中进行的,势必不会立即得到正确的最终结果,通过 Future 可以立即得到返回
*/
Future<String> findOrderDetails(long orderId);
/**
* 功能描述:提交订单,没有返回值
*
* @param account 用户信息
* @param orderId 订单编号
* @author cakin
* @date 2022/5/4
* @description: 它是一种无返回值的方法
*/
void order(String account, long orderId);
}
package concurrent.activeobject2;
import concurrent.future.Future;
import concurrent.future.FutureService;
import java.util.concurrent.TimeUnit;
/**
* @className: OrderServiceImpl
* @description: 在执行线程中将被使用的类
* @date: 2022/5/4
* @author: cakin
*/
public class OrderServiceImpl implements OrderService {
@Override
public Future<String> findOrderDetails(long orderId) {
return FutureService.<Long, String>newService().submit(input -> {
try {
TimeUnit.SECONDS.sleep(10);
System.out.println("Process the orderId->" + orderId);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "The order Details Information";
}, orderId, null);
}
@Override
public void order(String account, long orderId) {
try {
TimeUnit.SECONDS.sleep(10);
System.out.println("Process the order for account " + account + ",orderId " + orderId);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
package concurrent.activeobject2;
import concurrent.future.Future;
import java.util.HashMap;
import java.util.Map;
public class OrderServiceProxy implements OrderService {
private final OrderService orderService;
private final ActiveMessageQueue activeMessageQueue;
public OrderServiceProxy(OrderService orderService, ActiveMessageQueue activeMessageQueue) {
this.orderService = orderService;
this.activeMessageQueue = activeMessageQueue;
}
@Override
public Future<String> findOrderDetails(long orderId) {
// 定义一个 ActiveFuture,并且可支持立即返回
final ActiveFuture<String> activeFuture = new ActiveFuture<>();
// 收集方法入参以及返回的 ActiveFuture 封装成 MethodMessage
Map<String, Object> params = new HashMap<>();
params.put("orderId", orderId);
params.put("activeFuture", activeFuture);
MethodMessage message = new FindOrderDetailsMessage(params, orderService);
// 将 MethodMessage 保存到 activeMessageQueue
activeMessageQueue.offer(message);
return activeFuture;
}
@Override
public void order(String account, long orderId) {
// 收集方法参数,并且封装成 MethodMessage,然后 offer 到队列中
Map<String, Object> params = new HashMap<>();
params.put("account", account);
params.put("orderId", orderId);
MethodMessage message = new OrderMessage(params, orderService);
activeMessageQueue.offer(message);
}
}
package concurrent.activeobject2;
/**
* @className: OrderServiceFactory
* @description: 为了使 Proxy 的构造透明化,设计此工厂类
* @date: 2022/5/5
* @author: cakin
*/
public final class OrderServiceFactory {
private final static ActiveMessageQueue activeMessageQueue = new ActiveMessageQueue();
// 不允许外部通过 new 方式构造
private OrderServiceFactory() {
}
// 返回 OrderServiceProxy
public static OrderService toActiveObject(OrderService orderService) {
return new OrderServiceProxy(orderService, activeMessageQueue);
}
}
package concurrent.activeobject2;
import java.util.Map;
public abstract class MethodMessage {
// 用于收集方法参数,如果又返回 Future 类型,则一并收集
protected final Map<String, Object> params;
// 具体的接口实现
protected final OrderService orderService;
public MethodMessage(Map<String, Object> params, OrderService orderService) {
this.params = params;
this.orderService = orderService;
}
// 抽象方法,扮演 work thread 的说明书
public abstract void execute();
}
package concurrent.activeobject2;
import java.util.Map;
public class OrderMessage extends MethodMessage {
public OrderMessage(Map<String, Object> params, OrderService orderService) {
super(params, orderService);
}
@Override
public void execute() {
// 获取参数
String account = (String) params.get("account");
long orderId = (long) params.get("orderId");
// 执行真正的 order 方法
orderService.order(account, orderId);
}
}
package concurrent.activeobject2;
import concurrent.future.Future;
import java.util.Map;
public class FindOrderDetailsMessage extends MethodMessage {
public FindOrderDetailsMessage(Map<String, Object> params, OrderService orderService) {
super(params, orderService);
}
@Override
public void execute() {
// 执行 orderService 的 findOrderDetails 方法
Future<String> realFuture = orderService.findOrderDetails((Long) params.get("orderId"));
// 此方法会导致阻塞直到 findOrderDetails 方法完全执行结束
ActiveFuture<String> activeFuture = (ActiveFuture<String>) params.get("activeFuture");
// 当 findOrderDetails 执行结束时,将结果通过 finish 的方法传递给 activeFuture
try {
String result = realFuture.get();
activeFuture.finish(result);
} catch (InterruptedException e) {
activeFuture.finish(null);
}
}
}
package concurrent.activeobject2;
import concurrent.future.FutureTask;
/**
* @className: ActiveFuture
* @description: 执行线程完成任务之后传递最终结果
* @date: 2022/5/4
* @author: cakin
*/
public class ActiveFuture<T> extends FutureTask<T> {
@Override
public void finish(T result) {
super.finish(result);
}
}
package concurrent.activeobject2;
import java.util.LinkedList;
public class ActiveMessageQueue {
// 用于存放提交的 MethodMessage 消息
private final LinkedList<MethodMessage> messages = new LinkedList<>();
public ActiveMessageQueue() {
// 启动 Worker 线程
new ActiveDaemonThread(this).start();
}
public void offer(MethodMessage methodMessage) {
synchronized (this) {
messages.addLast(methodMessage);
// 因为只有一个线程负责 take 数据,因此没有必要使用 notifyAll 方法
this.notify();
}
}
protected MethodMessage take() {
synchronized (this) {
// 当 MethodMessage 队列中没有 Message 的时候,执行线程进入阻塞
while (messages.isEmpty()) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 获取其中一个 MethodMessage 并且从队列中移除
return messages.removeFirst();
}
}
}
package concurrent.activeobject2;
/**
* @className: ActiveDaemonThread
* @description: 守护线程,主要是从 queue 中获取 Message,然后执行 execute 方法
* @date: 2022/5/4
* @author: cakin
*/
public class ActiveDaemonThread extends Thread {
private final ActiveMessageQueue queue;
public ActiveDaemonThread(ActiveMessageQueue queue) {
super("ActiveDaemonThread");
this.queue = queue;
// ActiveDaemonThread 为守护线程
setDaemon(true);
}
@Override
public void run() {
while (true) {
// 从 MethodMessage 队列中获取一个 MethodMessage,然后执行 execute 方法
MethodMessage methodMessage = this.queue.take();
methodMessage.execute();
}
}
}
package concurrent.activeobject2;
import concurrent.future.Future;
public class Test {
public static void main(String[] args) throws InterruptedException {
// 需要传递 OrderService 的具体实现
OrderService orderService = OrderServiceFactory.toActiveObject(new OrderServiceImpl());
orderService.order("hello", 434543);
Future<String> orderDetails = orderService.findOrderDetails(434543);
String result = orderDetails.get();
System.out.println(result);
}
}
Process the order for account hello,orderId 434543
Process the orderId->434543
The order Details Information
关闭。这个问题需要更多focused .它目前不接受答案。 想改善这个问题吗?更新问题,使其仅关注一个问题 editing this post . 4年前关闭。 Improve this questi
.NET 框架:4.5.1 我在 Blend for visual studio 2015 中遇到一个奇怪的错误,我找不到它的来源。 如果我在 VS 中打开我的 WPF 解决方案,它会加载并运行良好。
我经常遇到这样的问题,与 Hierarchical RESTful URL design 非常相似 假设该服务仅提供用户上传文档。 POST, GET /accounts PUT, DELETE /a
在 Rails 应用程序中,我使用 devise 来管理我的用户,而我用来销毁 session 的链接不再有效。它正在工作,现在我添加了事件管理员,但没有。 我的链接是 :delete, :clas
我已经坚持了超过 24 小时,试图按照此处发布的其他解决方案进行操作,但我无法使其正常工作。我是 Rails 新手,需要帮助! 我想让我的/users/edit 页面正常工作,以便我可以简单地更改用户
Devise 在以下情况下不会使用户超时: 用户登录,关闭选项卡,然后在超时 + X 分钟内重新访问该 URL。用户仍处于登录状态。 如果选项卡已打开并且稍后刷新/单击,则超时可以正常工作。这意味着
我想使用这样的 slider 我希望该 slider 根据提供给它的值进行相应调整。到目前为止,我只能应用具有渐变效果的背景,但无法获得这种效果。请通过提供样式代码来帮助我。
您应该为每种方法创建一个请求/响应对象,还是应该为每个服务创建一个? 如果我在所有方法中使用它,我的服务请求对象中将只有 5 个不同的东西,因为我对几乎所有方法使用相同的输入。 响应对象将只有一个字典
我正在尝试在 REST 中对实体的附件进行建模。假设一个缺陷实体可以附加多个附件。每个附件都有描述和一些其他属性(上次修改时间、文件大小...)。附件本身是任何格式的文件(jpeg、doc ...)
我有以下表格: Blogs { BlogName } BlogPosts { BlogName, PostTitle } 博客文章同时建模一个实体和一个关系,根据 6nf(根据第三个宣言)这是无效的。
如果 A 类与 B、C 和 D 类中的每一个都有唯一的交互,那么交互的代码应该在 A 中还是在 B、C 和 D 中? 我正在编写一个小游戏,其中许多对象可以与其他对象进行独特的交互。例如,EMP点击
关于如何记住我与 Omniauth 一起工作似乎有些困惑。 根据这个wiki ,您需要在 OmniauthCallbacksController 中包含以下内容: remember_me(user)
设计问题: 使用 非线程安全 组件(集合,API,...)在/带有 多线程成分 ... 例子 : 组件 1 :多线程套接字服务器谁向消息处理程序发送消息... 组件 2 :非线程安全 消息处理程序 谁
我们目前正在设计一个 RESTful 应用程序。我们决定使用 XML 作为我们的基本表示。 我有以下关于在 XML 中设计/建模应用程序数据的问题。 在 XML 中进行数据建模的方法有哪些?从头开始然
我正在设计一个新的 XSD 来从业务合作伙伴那里获取积分信息。对于每笔交易,合作伙伴必须提供至少一种积分类型的积分值。我有以下几点:
设计支持多个版本的 API 的最佳方法是什么。我如何确保即使我的数据架构发生更改(微小更改),我的 api 的使用者也不会受到影响?任何引用架构、指南都非常有用。 最佳答案 Mark Nottingh
关闭。这个问题是opinion-based 。目前不接受答案。 想要改进这个问题吗?更新问题,以便 editing this post 可以用事实和引文来回答它。 . 已关闭 4 年前。 Improv
我想用 php 创建一个网站,其工作方式与 https://www.bitcoins.lc/ 相同。确实,就每个页面上具有相同布局但内容会随着您更改链接/页面而改变而言,我如何在 php 中使用lay
我有一个关于编写 Swing UI 的问题。如果我想制作一个带有某些选项的软件,例如在第一个框架上,我有三个按钮(新建、选项、退出)。 现在,如果用户单击新按钮,我想将框架中的整个内容更改为其他内容。
我正在尝试找出并学习将应用程序拥有的一堆Docker容器移至Kubernetes的模式和最佳实践。诸如Pod设计,服务,部署之类的东西。例如,我可以创建一个其中包含单个Web和应用程序容器的Pod,但
我是一名优秀的程序员,十分优秀!