servicedelegate.getport 创建的代理可以重用吗?它是线程安全的吗?

发布于 2024-11-09 12:05:44 字数 180 浏览 0 评论 0原文

我们正在使用 webservice(通过 websphere),为了提高性能,我们相信我们可以缓存由 servicedelegate.getport(..) 创建的代理,因为每次创建代理都是昂贵的。

现在,我们的问题是,线程安全吗?想象一下,我们有 10 个线程同时运行,它们将获取同一个代理,并同时使用它。

谢谢

We are using webservice (through websphere), to improve performance, we believe we can cache proxy created by servicedelegate.getport(..) since creating proxy every time is expensive.

Now, our question is, is it thread safe? Just image, we have 10 threads running at the same time, they will grab the same proxy, and use it at the same time.

Thx

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

空气里的味道 2024-11-16 12:05:44

不要让您的应用程序缓存它,只需使用 WebServiceRef 注入它并让容器为您管理它。

Instead of letting your application cache it, just have it injected using WebServiceRef and let the container manage it for you.

素手挽清风 2024-11-16 12:05:44

端口不是线程安全的。它们保留状态,如 javax.xml.ws.handler.MessageContext。但端口对象以后可以安全地重用!

在调用之前将端口缓存在 LinkedBlockingQueue 中,并在调用之前peek,然后使用 offer 返回。

在以下实现中,port 对象不会从 call 代码中泄漏,因此可以安全地重用它:

private LinkedBlockingQueue<Port> portCache = new LinkedBlockingQueue<>();

public Rsp call(Req req) {
    Port port = portCache.poll();
    if (port == null) {
        port = createPort();
    }
    BindingProvider provider = (BindingProvider) port;
    try {
        return portMethod.invoke(port, req);
    } finally {
        portCache.offer(port);
    }
}

Ports are not thread safe. They keep state, like javax.xml.ws.handler.MessageContext. But port object can be safely reused later!

Cache ports in LinkedBlockingQueue and peek before call and then return after with offer.

In following implementation port object doesn't leak out of call code so it is safe to reuse it:

private LinkedBlockingQueue<Port> portCache = new LinkedBlockingQueue<>();

public Rsp call(Req req) {
    Port port = portCache.poll();
    if (port == null) {
        port = createPort();
    }
    BindingProvider provider = (BindingProvider) port;
    try {
        return portMethod.invoke(port, req);
    } finally {
        portCache.offer(port);
    }
}
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文