中间件WebLogic/Tuxedo/GoldenGate的排错与优化（获奖名单已公布）

三人行必有吾师

回复 92# 鸣禽云霞出海曙
至于WebLogic，前面有位同学说得好，可以反编译weblogic.jar文件；先解压缩，再用Jad之类的工具，基本上可以倒腾出个大概；只是其中没有了注释和变量名的准确定义，所以需要读代码的能力超强。。。

其实WebLogic的代码和大家熟悉的Java代码类似(不过NativeIO那块有JNI调C)，比如ClusterService.java

1. package weblogic.cluster;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.InetAddress;
   
5. import java.net.UnknownHostException;
   
6. import java.util.Collection;
   
7. 
   
8. import weblogic.cluster.replication.ReplicationManager;
   
9. import weblogic.common.internal.VersionInfo;
   
10. import weblogic.kernel.Kernel;
    
11. import weblogic.management.Admin;
    
12. import weblogic.management.configuration.ClusterMBean;
    
13. import weblogic.management.configuration.ServerMBean;
    
14. import weblogic.rjvm.JVMID;
    
15. import weblogic.rmi.spi.RMIRuntime;
    
16. import weblogic.server.Server;
    
17. import weblogic.server.ServerLifeCycle;
    
18. import weblogic.server.ServerLifecycleException;
    
19. 
    
20. 
    
21. /**
    
22. * Implements lifecycle for internal cluster service.  This controls
    
23. * features of the cluster subsystem that are used by other subsystems.
    
24. * It is inialized early in server startup to ensure that other
    
25. * subsystems can use can access its services during initialization.
    
26. * This class also the ClusterServices interface, which gives other
    
27. * subsystems access to clustering machinery.
    
28. *
    
29. * @author Copyright (c) 1996-98 by WebLogic, Inc. All Rights Reserved.
    
30. * @author Copyright (c) 1999-2000 by BEA WebXpress. All Rights Reserved.
    
31. */
    
32. 
    
33. final public class ClusterService implements ServerLifeCycle, ClusterServices
    
34. {
    
35.   private static ClusterService singleton = null;
    
36.   private static boolean clusterMemberInitialized = false;
    
37. 
    
38.   /* package */ static final String MULTICAST_QUEUE = "Multicast";
    
39. 
    
40.   private static final ClusterTextTextFormatter formatter =
    
41.     new ClusterTextTextFormatter();
    
42. 
    
43.   public ClusterService() {
    
44.     singleton = this;
    
45.   }
    
46. 
    
47.   /** This accessor is ONLY for the server initialization mechanism.
    
48.    *  If you are a client, use the static getServices() call instead.
    
49.    */
    
50.   public static ClusterService getClusterService() {
    
51.     return singleton;
    
52.   }
    
53. 
    
54.   private ClusterMBean clusterMBean;
    
55.   private MemberAttributes localAttributes;
    
56.   private static boolean isServerInCluster = false;
    
57.   private String clusterName;
    
58. 
    
59.   public void initialize()
    
60.     throws ServerLifecycleException
    
61.   {
    
62.     ServerMBean serverMBean = Server.getConfig();
    
63.     clusterMBean = serverMBean.getCluster();
    
64. 
    
65.     String machineName = (serverMBean.getMachine() == null) ?
    
66.       Kernel.getConfig().getName() : serverMBean.getMachine().getName();
    
67.     if (clusterMBean != null) {
    
68.       // Set ServerInfo on local server
    
69.       weblogic.rmi.cluster.ServerInfoManager.theOne().addServer(
    
70.         serverMBean.getName(),
    
71.         RMIRuntime.getLocalHostID(),
    
72.         serverMBean.getClusterWeight()
    
73.       );
    
74.       // Figure out the multicast address for the cluster
    
75.       clusterName = clusterMBean.getName();
    
76.       String address = clusterMBean.getMulticastAddress();
    
77.       if (address == null || address.equals("")) {
    
78.         // may be null if config entry is missing
    
79.         // do not provide any default multicast address but flag a config error
    
80.         ClusterLogger.logMissingClusterMulticastAddressError(clusterName);
    
81.         // we can not go ahead, stop the ongoing startupMode
    
82.         throw new ServerLifecycleException(
    
83.           "configuration problem - missing multicast address for cluster: " +
    
84.           clusterName);
    
85.       }
    
86.         
    
87.       
    
88.       // Check cluster address
    
89.       String clusterAddress = clusterMBean.getClusterAddress();
    
90.       boolean clusterAddressResolved = true;
    
91.       if (clusterAddress != null) {
    
92.         int nodeNumber = 0;
    
93.         String[] nodeAddress = weblogic.utils.StringUtils.splitCompletely(
    
94.                                     clusterAddress, ",", false);
    
95.         char delimiter = (char) (new String(":")).charAt(0);  
    
96.         try {
    
97.           if (nodeAddress.length>1) {
    
98.             // Honor comma seperated ip list for cluster address.
    
99.             // This is allowed only for Development mode.
    
100.             while(nodeNumber<nodeAddress.length) {
     
101.               // handle port number at the end
     
102.               String nodeNameOrAddress = weblogic.utils.StringUtils.upto(
     
103.                     nodeAddress[nodeNumber],delimiter);
     
104.                               
     
105.               InetAddress.getByName(nodeNameOrAddress);
     
106.               nodeNumber++;
     
107.             }
     
108.           } else {
     
109.             // We are in production mode.
     
110.             // We should have a DNS entry properly setup
     
111.             InetAddress.getByName(clusterAddress);
     
112.           }  
     
113.           weblogic.rjvm.JVMID.localID().setClusterAddress(clusterAddress);
     
114.         } catch (UnknownHostException e) {
     
115.           if (nodeAddress.length>1) {
     
116.             ClusterLogger.logCannotResolveClusterAddressWarning(
     
117.               clusterAddress+": Unknown host: "+nodeAddress[nodeNumber]);
     
118.           } else {
     
119.             ClusterLogger.logCannotResolveClusterAddressWarning(
     
120.               clusterAddress);
     
121.           }
     
122.         }
     
123.       }
     
124.       // Check the license and if OK, initialize everything
     
125.       try {
     
126.         checkProcess();
     
127.         // Set up the local attributes. If any of these values ever
     
128.         // change, stuff them into the localAttributes object and call
     
129.         // AttributeManager.theOne().sendAttributes(localAttributes).
     
130.         // The code is in place to carry the object to the other
     
131.         // cluster members and fire ClusterMembersChangeEvent.UPDATE.
     
132.         // A few tasks remain before this will be useful however.
     
133.         // 1) There is no machinery in place to notify consumers of
     
134.         //    localAttributes on the *local* server.
     
135.         // 2) ClusterMembersListeners on the remote servers may
     
136.         //    not have code to respond to UPDATE events.
     
137.         // 3) The code has not been tested.
     
138. 
     
139.         localAttributes = new MemberAttributes(
     
140.           (JVMID) RMIRuntime.getLocalHostID(), serverMBean.getName(),
     
141.           serverMBean.getListenAddress(), machineName,
     
142.           VersionInfo.theOne().getReleaseVersion(), System.currentTimeMillis(),
     
143.           serverMBean.getClusterWeight(),
     
144.           serverMBean.getReplicationGroup(),
     
145.           serverMBean.getPreferredSecondaryGroup(),
     
146.           Admin.getInstance().getActiveDomain().getName(),
     
147.           clusterName);
     
148.         
     
149.         MulticastManager.initialize(
     
150.           clusterMBean.getMulticastAddress(),
     
151.           Server.getConfig().getInterfaceAddress(),
     
152.           clusterMBean.getMulticastPort(),
     
153.           (byte)clusterMBean.getMulticastTTL(),
     
154.           clusterMBean.getMulticastSendDelay()
     
155.         );
     
156.         
     
157.         // Initialize the managers and the cluster runtime MBean.
     
158.         AnnouncementManager.initialize(
     
159.           clusterMBean.getServiceAgeThresholdSeconds()
     
160.         );
     
161.         MemberManager.initialize(localAttributes.joinTime());
     
162.         AttributeManager.initialize(localAttributes);
     
163.         ReplicationManager.initialize(
     
164.           machineName,
     
165.           serverMBean.getReplicationGroup(),
     
166.           serverMBean.getPreferredSecondaryGroup()
     
167.         );
     
168.         ClusterRuntime.initialize(Server.getConfig().getName(), clusterName);
     
169.         // We use only one thread to ensure ordered processing
     
170.         Kernel.addExecuteQueue(MULTICAST_QUEUE, 1);
     
171.         isServerInCluster = true;
     
172.       } catch (com.bea.utils.misc.ProcessException le) {
     
173.         ClusterLogger.logNoClusterLicenseError(le);
     
174.         throw new ServerLifecycleException(le.getMessage());
     
175.       } catch (IOException ioe) {
     
176.         ClusterLogger.logFailedToJoinClusterError(
     
177.           clusterName, clusterMBean.getMulticastAddress(), ioe);
     
178.         throw new ServerLifecycleException(ioe);
     
179.       }
     
180.     }
     
181.   }
     
182. 
     
183.   public void prepareToSuspend()
     
184.     throws ServerLifecycleException
     
185.   {
     
186.   }
     
187. 
     
188.   public void forceSuspend() throws ServerLifecycleException {
     
189.     if (isServerInCluster)
     
190.       MulticastManager.theOne().forceSuspend();
     
191.   }
     
192. 
     
193.   public void resume() throws ServerLifecycleException {
     
194.     if (isServerInCluster)
     
195.       MulticastManager.theOne().resume();
     
196.   }
     
197. 
     
198.   public void shutdown() throws ServerLifecycleException
     
199.   {
     
200.     if (clusterMBean != null) {
     
201.       MemberManager.theOne().shutdown();
     
202.       AnnouncementManager.theOne().shutdown();
     
203.     }
     
204.   }
     
205.    
     
206.   ///////////////////////////////////
     
207.   // For ClusterServices Interface //
     
208.   ///////////////////////////////////
     
209. 
     
210.   /** Returns null if the server is either not configured to run in a
     
211.    *  cluster or the cluster mechanisms could not be started.
     
212.    *  The cluster mechanisms are considered started for this purpose
     
213.    *  if this service was initialized successfuly.
     
214.    */
     
215.   public static ClusterServices getServices() {
     
216.     if (isServerInCluster)
     
217.       return getClusterService();
     
218.     else
     
219.       return null;
     
220.   }
     
221. 
     
222.   /* package */ MulticastSession createMulticastSession(int senderID,
     
223.     RecoverListener listener,
     
224.     int cacheSize,
     
225.     boolean useHTTPForStateDumps) {
     
226.     return MulticastManager.theOne().createSender(senderID, listener, cacheSize, useHTTPForStateDumps);
     
227.   }
     
228.   public MulticastSession createMulticastSession(RecoverListener listener,
     
229.     int cacheSize, boolean useHTTPForStateDumps) {
     
230.     return createMulticastSession(-1, listener, cacheSize, useHTTPForStateDumps);
     
231.   }
     
232. 
     
233.   public ClusterMemberInfo getLocalMember() {
     
234.     return localAttributes;
     
235.   }
     
236. 
     
237.   public Collection getRemoteMembers() {
     
238.     return MemberManager.theOne().getRemoteMembers();
     
239.   }
     
240. 
     
241.   public void addClusterMembersListener(ClusterMembersChangeListener listener) {
     
242.     MemberManager.theOne().addClusterMembersListener(listener);
     
243.   }
     
244. 
     
245.   public void removeClusterMembersListener(ClusterMembersChangeListener listener) {
     
246.     MemberManager.theOne().removeClusterMembersListener(listener);
     
247.   }
     
248. 
     
249.   public void addHeartbeatMessage(GroupMessage message)
     
250.   {
     
251.     MulticastManager.theOne().addItem(message);
     
252.   }
     
253. 
     
254.   public void removeHeartbeatMessage(GroupMessage message)
     
255.   {
     
256.     MulticastManager.theOne().removeItem(message);
     
257.   }
     
258. 
     
259.   // check license
     
260.   private static boolean l_did  = false;  
     
261.   private void checkProcess() throws com.bea.utils.misc.ProcessException {
     
262.     if (!l_did) {
     
263.       String l_comp = "Cluster";
     
264.       com.bea.utils.misc.Process l_lic;
     
265.       java.util.Properties l_prop = new java.util.Properties();        
     
266.       l_prop.put("product", weblogic.version.getPLInfo()[0]);
     
267.       l_prop.put("release",   weblogic.version.getPLInfo()[1]);
     
268.       l_prop.put("component", l_comp);
     
269.       l_prop.put("ip", "");
     
270.       try {
     
271.         l_lic = com.bea.utils.misc.ProcessManager.memCheck(l_prop);
     
272.         formatter.startingClusterService();
     
273.       } catch (com.bea.utils.misc.ProcessException l_ex) {
     
274.         System.err.println("\n\n$$$$$$$$$$$$$$$$ \u004c\u0069\u0063\u0065\u006e\u0073\u0065 \u0045\u0078\u0063\u0065\u0070\u0074\u0069\u006f\u006e $$$$$$$$$$$$$$$$\n\n");
     
275.         System.err.println("Unable to start Cluster Service!");
     
276.         System.err.println(l_ex.getMessage());
     
277.         System.err.println("\n\n$$$$$$$$$$$$$$$$ \u004c\u0069\u0063\u0065\u006e\u0073\u0065 \u0045\u0078\u0063\u0065\u0070\u0074\u0069\u006f\u006e $$$$$$$$$$$$$$$$\n\n");
     
278.         throw l_ex;
     
279.       } finally {
     
280.         l_did = true;
     
281.       }
     
282.     }
     
283.   }
     
284. }

复制代码

里面大家可以看到原始的WebLogic Inc.的标记，这其实也符合历史事实；因为WebLogic最早也是BEA买来的，那个时候产品不叫WebLogic，被并购的公司叫WebLogic

1. *
   
2. * @author Copyright (c) 1996-98 by WebLogic, Inc. All Rights Reserved.
   
3. * @author Copyright (c) 1999-2000 by BEA WebXpress. All Rights Reserved.
   
4. */

复制代码

另外，象最后一段是校验License的逻辑，意味着最早的WebLogic中，要是想跑Cluster的话，是需要单独额外的License字段授权的。


这个方面我们就先到这里吧，敏感话题，以后不再碰和涉及；不过一定还会经常回来

sometimeixpub

才看到，戴工可好

永不变的承诺

WebLogic和Tuxedo都怎么互联互通呢？

IT-寻梦人

Tuxedo支持WebService吗，效果如何？

maya_2012

看来暂时是用不上这些高深的东西了

shaneqi

如果跟导师讲不清楚，那么就把他搞胡涂吧!

勤奋真能造就财富吗？

三人行必有吾师

回复 103# 永不变的承诺

1. 最早的方式是用Jolt，就是把Tuxedo/WS，写了一套Java版本的远程客户端，同时服务端模拟WSL/WSH，添加了一套JSL/JSH；这个是基于客户端/服务器访问方式的；它的好处是，不局限于WebLogic，只要是Java上的容器都可以，比如竞争对手WebSphere；

2. 后来比较成熟的是WTC，顾名思义，WebLogic和Tuxedo连接器，这个是不需要在Tuxedo这端额外添加什么组件，只是继续用传统的GWTDOMAIN，这个是基于Tuxedo域之间通讯的机制，在Java端模拟的是Tuxedo的远程对等域；它的问题是，由于Java的各种Package封装，其全局事务时很多时候都隐含，会把全局事务不自觉的扩展到Tuxedo这端

3. 再后来是符合规范的JCA框架，这个就是按标准制作了。


   

三人行必有吾师

回复 104# IT-寻梦人

WebLogic比较早就支持Web Service，所以早先有人在WebLogic这端实现Web Service接口，然后通过WTC调用Tuxedo的服务(好象还跟上个回复有关联似的。。)；

后来Tuxedo单独开发了SALT，自己就可以独立支持Web Service了；SALT的思路有点象JOLT，不过在服务端配的是GWWS，也是配配定义文件，就将传统的Tuxedo服务，对外发布成Web Service。

从我们实际实施过的经验来看，相对于走网关而言，Inbound还是有明显优势，非常快；Outbound则没有明显优势。

三人行必有吾师

回复 102# sometimeixpub
似是故人来，握手，问好

回复 105# maya_2012
其实看了源代码反而不容易觉得高深了，否则常觉得产品比较神奇

回复 106# shaneqi
问好，看不太懂意思，不过勤奋总是不会错的


   

swokaob

对于WebService的支持，Oracle有什么专门的产品吗？