- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我通过删除我的帖子打开了这个问题,其中我错误地提出了问题,包括标题,并且提供的信息不多。我的问题是线程请求和响应在某些情况下会交换。
下面是应用程序的weblogic日志和代码
从日志中我发现线程正在交换..下面是 weblogic 日志假设两个线程(7,8)处理两个portId (1234,4567)的performX()
<DEBUG> 2016-05-11 16:55:45,319 [ExecuteThread: '7'----] processing data for port id = 1234
<DEBUG> 2016-05-11 16:XX:YY,319 [ExecuteThread: '8'----] processing data for port id = 4567
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '7'----] ResponseQueue :: getResponse() :: ResponseQueue456
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '7'----] ResponseQueue :: getResponse() :: Reading Data from stream :: ResponseQueue456
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '7'----] ResponseQueue :: getResponse() :: Reading Data from stream completed :: ResponseQueue456
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '7'----]:: ReturnXML=<xml>---<order_number>4567</order_number> ---</xml>
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '7'----]:: Adding ordernumber as Key = 4567 value = ReturnXmlObjet1234
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '7'----]:: Getting object of port Key = 1234 value = null
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '8'----] ResponseQueue :: getResponse() :: ResponseQueue456
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '8'----] ResponseQueue :: getResponse() :: Reading Data from stream :: ResponseQueue456
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '8'----] ResponseQueue :: getResponse() :: Reading Data from stream completed :: ResponseQueue456
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '8'----]:: ReturnXML=<xml>---<order_number>1234</order_number> ---</xml>
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '8'----]:: Adding ordernumber as Key = 1234 value = ReturnXmlObjet4567
<DEBUG> 2016-05-11 16:XX:YY [ExecuteThread: '8'----]:: Getting object of port Key = 4567 value = ReturnXmlObjet1234
如果您清楚地看到线程 7 和线程 8 正在交换,因为线程 7 的映射值即将为空,则我们将抛出应用程序特定的错误。下面是代码。如何避免这种情况。
我正在提取实时生产代码和日志。
Class A{
----
B bobj = B.getInstance()
Map map = new HashMap();
public void performX(String portid){
logger.debug("Processing data for portId = "+ portId);
returnXml = bobj.getResponse(); // bobj is a singleton
logger.debug("returnXML ="+ retunrXML);
ReturnXmlObjet r_obj = convertToObject(returnXMl);
// retunrXml contain a field orderNumber which must be same as
// portid method parameter
if(r_obj != null){
logger.debug("Adding ordernumber as Key = "+ r_obj.getOrderNumber()+ "Value is =" + r_obj);
map.put(r_obj.getOrderNumber,r_obj);
}
r_obj = map.get(portid);
logger.debug("Getting object of port Key = "+ r_obj.getOrderNumber()+ "Value is =" + r_obj);
if(r_obj == null){
throw new ApplicationSpecificException("Not able to get Response");
}
}
}
Class B(){
B instance = null;
public static synchronized BgetInstance() throws AboxRetryException {
if (instance == null) {
instance = new B();
}
return instance;
}
public synchronized String getResponse() {
logger.debug(" ResponseQueue :: getResponse() :: "+ this);
String returnXML = null;
String strResponseACK;
InstantLinkXML ilXML = new InstantLinkXML();
try {
logger.debug(" ResponseQueue :: Reading Data from stream :: "+ this);
returnXML = in.readLine();
logger.debug(" ResponseQueue :: Reading Data completed from stream :: "+ this);
} catch (IOException ioe) {
logger.error("Failure getting Response");
} catch(Exception e){
logger.error(e.getMessage());
}
if (returnXML != null) {
// Send ACK
strResponseACK = ilXML.getxxx();
out.println(strResponseACK);
}
//code to convert XML to Java object.. ReturnObject has a property port_db
return returnXML;
}
Below is the code for *in* object initialization. This login() method is called in the class constructor where getResponsed() method is written
public String logIn() {
String returnXML = null;
try {
String strUser = ConfigItemsAccess.getConfigItems("o2.xxx.user");
String strPass = ConfigItemsAccess.getConfigItems("o2.xxx.password");
String strServer = ConfigItemsAccess.getConfigItems("o2.xxx.server");
int iPort = Integer.parseInt(ConfigItemsAccess.getConfigItems("o2.xxx.respport"));
logger.debug("logIN :: strUser="+strUser+" strPass="+strPass+" strServer="+strServer+ " iport = "+ iPort );
String strLoginRequest;
String strLoginAck;
InstantLinkXML ilXML = new InstantLinkXML();
try {
XXXSocket( Just a SOCKET object abstracted according to application) = new Socket(strServer, iPort);
xxxSocket.setKeepAlive(true); //new
out = new PrintWriter(xxxSocket.getOutputStream(), true);
in = new BufferedReader(new InputStreamReader(xxxSocket.getInputStream()));
} catch (UnknownHostException e) {
logger.error("Cannot connect to host: " + e.getMessage());
} catch (IOException e) {
logger.error("Couldn't get I/O for the connection to:" + strServer + ":" + iPort);
// Connect to Secondary Server
strServer = ConfigItemsAccess.getConfigItems("o2.xxx.server.backup");
try {
logger.debug("Connecting to Secondary Server: " + strServer);
xxxSocket = new Socket(strServer, iPort);
xxxSocket.setKeepAlive(true); //new
out = new PrintWriter(xxxSocket.getOutputStream(), true);
in = new BufferedReader(new InputStreamReader(xxxSocket.getInputStream()));
} catch (UnknownHostException e2) {
logger.error("Cannot connect to host: " + e2.getMessage());
}
}
} catch (IOException e2) {
logger.error("Couldn't get I/O for the Secondary connection to:" + strServer + ":" + iPort);
}
} catch(Exception e){
logger.error(e.getMessage());
}
strLoginRequest = ilXML.getLogInRequest(strUser, strPass);
out.println(strLoginRequest);
try {
strLoginAck = in.readLine();
returnXML = strLoginAck;
} catch (IOException ioe) {
logger.error("Failure getting Comptel Ack back");
} catch(Exception e){
logger.error(e.getMessage());
}
}
catch (FinderException Ex) {
logger.error("FinderException trying to get o2.xxx from CONFIGITEMS\n" + Ex.getMessage());
throw new java.lang.NullPointerException("Exception trying to get config items");
}
catch (Exception e){
logger.error(e.getMessage());
}
return returnXML;
}
ilXML.getLogInRequest(String strUser, String strPass){
return ("<Message version=\"SAS3\">\n" + " <LOGIN\n" + " LOGIN=\""
+ strUser + "\"\n" + " PASSWORD=\"" + strPassword + "\"/>\n" + "</Message>\n");
}
Socket从EjbApplication(JAR文件)读取信息
请您帮助我,这个问题的根本原因是什么以及如何解决它。让我知道还需要更多信息。
最佳答案
看起来 returnXml 是在您的方法之外声明的。当您调用 getResponse() 时,您将覆盖之前的内容。
关于java - 线程响应在 weblogic 部署的应用程序中交换,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37222266/
我在 *.sql 文件中得到了我的数据库转储(表、函数、触发器等)。此时我正在通过 jenkins 部署它们,通过传递执行 shell 命令: sudo -u postgres psql -d my_
我正在使用网络部署 API 来部署网络包(.zip 文件,由 MSDeploy.exe 创建)以编程方式将包发布到服务器(在发布包之前我们需要做一些其他事情这就是为什么我们不使用 MSDeploy.e
我们正在使用 Web Deploy 3 的(几乎完全未记录的)“公共(public) API”来创建我们网站的 .zip 包,然后将其同步到服务器: DeploymentBaseOptions des
将 clojure 应用程序制作成可执行文件的最简单方法是什么,例如 http://rawr.rubyforge.org/ ruby 吗? (exe 和 app 文件也是) 最佳答案 使用 leini
是否可以下载 Android 源代码并针对任何设备进行编译? 我想做的是尝试 GSM 代码部分并编译操作系统并将其部署到我的摩托罗拉手机上。 谢谢! 最佳答案 是的,但这很难,因为大多数手机不共享驱动
我正在考虑用 c/c++ 编写需要在大多数个人计算机上运行的 nbody 样式模拟。本质上是一个 O(n^2) 粒子模拟器。 因为这需要相当用户友好,所以我希望有 1 个不需要用户安装任何东西的 Wi
需要了解 kubernetes 部署中 kube_deployment_status_replicas 和 kube_deployment_spec_replicas 指标的区别 最佳答案 简而言之,
我正在尝试使用分类器部署 Maven Artifact 。由于我需要源代码和 JAR(我从 GWT 使用它),我想获得 artifact-version-classifier.jar 和 artifa
我设置部署以将我的项目代码与存储我的网站的 FTP 服务器上的项目同步。 但是,每次尝试同步时,我总是必须登录。 我什至检查了记住,但它不起作用! 我正在使用最新的 PhpStorm 2017.1.4
我在 Visual Studio 2008 中开发了一个 ASP.NET 网站。现在我想在其他机器上部署它。我怎样才能做到这一点??就像我们为 Windows 应用程序制作安装包一样,我们可以为 AS
将 QT 框架添加到我的 .app 包中 我正在关注 Qt 站点上关于部署的文档。 我创建了一个名为 HTTPClient.app 的应用程序 我在 Contents 下创建了 Framework 文
这个问题不太可能对任何 future 的访客有帮助;它只与一个小的地理区域、一个特定的时间点或一个非常狭窄的情况相关,通常不适用于互联网的全局受众。如需帮助使这个问题更广泛适用,visit the h
我正在研究改变我目前创建营销网站的策略。目前,我完全用 PHP 从头开始构建网站,使用一个简单的包含系统。所有代码(以及内容)都存储在文件(而不是数据库)中,允许我使用 Subversion 进行
我有一个长期运行的服务(在 while 1 循环中)并通过 GCloud pub/sub 处理有效负载,之后它将结果写入数据库。 该服务不需要监听任何端口。 Kind=Deployment 的声明性
似乎部署已停滞不前。我该如何进一步诊断? kubectl rollout status deployment/wordpress Waiting for rollout to finish: 2 ou
我正在Dart中使用前端的Angular和后端的Shelf构建一个客户端/服务器应用程序。当我执行pub build时,它会按预期生成Dart文件的javascript,但不会替换HTML文件中的Da
我在 Azure 部署中心的下拉列表中看不到我的所有 Github 组织存储库。 Azure 很久以前就已经被授权了,下拉列表正确地显示了所有的存储库,直到上周我在 DevOps 中玩游戏时,不得不再
我认为标题几乎说明了一切...对于 Deployd 来说是全新的,所以任何关于如何最好地实现这一点的指示都值得赞赏。 最佳答案 要获取用户创建的集合中的对象(我假设您使用的是 javascript 库
我有一个试图用于CD服务器的部署脚本,但是在编写bash脚本以完成一些所需的步骤(例如运行npm和迁移命令)时遇到了问题。 我将如何从该脚本进入容器bash,运行下面的命令,然后退出以完成对更改的提取
我想在使用 kubectl 时将参数传递给 Kubernetes 部署命令应用部署文件。 示例:在我的部署 .yaml 中,我有如下参数,我想在使用 kubectl apply - f .yaml 运
我是一名优秀的程序员,十分优秀!