用 Proxy 简化加锁代码，用 ReadWriteLock 以提高并行性

用 java.lang.reflect.Proxy 简化加锁代码，用 ReadWriteLock 以提高并行性

 

有一个 CoreManager 接口，用来代表一个服务，每个方法对应服务的一个子功能。

 

方法 startup() 要求服务在 stoped 状态。

方法 shutdown() 要求服务在 started 状态。

方法 isStarted() 要求服务在 stoped/started 状态。

其它方法，要求服务在 started 状态。

 

 

/**

 *Allmehtodwillthrow{@link ManageException}thenTargetserverstoped.

 *

 */

publicinterface CoreManager {

 

      // ------- Target Server Control ---------------------------

      /**

       *ShutdownTargetServerCore.

       * 

       *@throwsManageExceptionstartuperror

       */

      publicvoid startup() throws ManageException;

 

      /**

       *ShutdownTargetServerCore.

       * 

       *@throwsManageExceptionshutdownerror

       */

      publicvoid shutdown() throws ManageException;

     

      /**

       *returntureifTargetServerisstarted

       *@returntheresult

       *  

       */

      publicboolean isStarted();

     

      /**

       *Reconfigurethelogsetting

       *

       *@paramlogConfig

       *@throwsManageException

       */

      publicvoid configureLog(LogConfig logConfig) throws ManageException;

 

      // ------- Component Manage-------------------------------

      /**

       *Addcomponent.

       *

       *@paramcomponentInfo

       *@throwsManageExceptionaddfail.

       */

      publicvoid addComponent(AbstractComponentBean componentInfo)

                  throws ManageException;

 

      /**

       *Returnallcomponentnames.

       *

       *@returnnotnull

       *@throwsManageException

       */

      public String[] getAllComponentNames() throws ManageException;

 

      /**

       *Returnthecomponentsetting.

       *

       *@paramcomponentName

       *@returnresultnotnull

       *@throwsManageExceptioncomponentnotfound

       */

      public AbstractComponentBean getComponentInfo(String componentName)

                  throws ManageException;

 

      /**

       *Removecomponent.

       *

       *@paramcomponentName

       *@throwsManageExceptioncomponentnotfound

       */

      publicvoid removeComponent(String componentName) throws ManageException;

 

      /**

       *Applynewroutinggraph

       *

       *@deprecateduse{@link #setNewRouting(ComponentConnector[])}instead

       *@paramroutingBeans

       *@returntureonlyifallconnectorisseted

       *@throwsManageException

       */

      @Deprecated

      publicboolean setNewRouting(ConnectorBean[] routingBeans) throws ManageException;

 

      /**

       *Applynewroutinggraph

       *

       *@paramroutingBeans

       *@returntureonlyifallconnectorisseted

       *@throwsManageException

       */

      publicboolean setNewRouting(ComponentConnector[] routingBeans) throws ManageException;

 

      /**

       *Changecomponentsetting

       *

       *@paramcomponentBean

       *@throwsManageExceptioncomponentnotfound

       */

      publicvoid changeComponentSetting(AbstractComponentBean componentBean)

                  throws ManageException;

 

      /**

       *Returntrueifcomponentexsit.

       *

       *@paramcomponentName

       *@returntheresult

       *@throwsManageException

       */

      publicboolean isComponentExist(String componentName) throws ManageException;

 

      /**

       *Getthedevicecomponentstatus.

       *Ifthecomponentin<code>componentNames</code>notexist,UNKNOWNwillreturn.

       *

       *@paramcomponentNames

       *@returnresult

       *@throwsManageException

       */

      public ConnectionStatus[] getDeviceComponentStatus(String[] componentNames) throws ManageException;

 

      /**

       *Settheenabledpropertyofcomponent.

       *

       *@paramcomponentName

       *@paramenabled

       *@throwsManageExceptioncomponentnotfound.

       */

      publicvoid setComponentEnabledProperty(String componentName,

                  boolean enabled) throws ManageException;

 

      // ------- Reader Control ----------------------------------

      publicvoid setAutoModeOn(String deviceName) throws ManageException;

 

      publicvoid setAutoModeOff(String deviceName) throws ManageException;

 

      public String getVersionNumber(String readerName) throws ManageException;

 

      publiclong getNumberOfReads(String readerName) throws ManageException;

 

      publiclong[] getNumberOfReads(String[] readerNames) throws ManageException;

 

      public Collection<DRFITag> readTags(String readerName)

                  throws ManageException;

 

      public Collection<DRFITag> readTags(String readerName, int antennaSequenceNo)

                  throws ManageException;

 

      public Collection<DRFITag> readTags(String readerName,

                  int[] antennaSequenceNo) throws ManageException;

 

      publicvoid writeTag(String deviceName, String writeFlag, String epc,

                  String userData, String killCode, int antennaSequenceNo)

                  throws ManageException;

 

      publicvoid killTag(String deviceName, String uri, String killCode,

                  int antennaSequence) throws ManageException;

 

      publicvoid setReadPower(String deviceName, int powerPercent)

                  throws ManageException;

 

      /**

       *Sendacommand(Event)toacomponent

       *

       *@paramtargetCompName

       *@paramevent

       *@returnmaynull

       *@throwsManageExceptionComponentnotfound/stoped.

       */

      public Object sendEvent2Component(String targetCompName, Object event)

                  throws ManageException;

 

      /**

       *Sendacommand(Event)toacomponent

       *

       *@paramtargetCompName

       *@paramsrcCompInfo

       *@paramevent

       *@returnmaynull

       *@throwsManageExceptionComponentnotfound/stoped.

       */

      public Object sendComponentEvent2Component(String targetCompName,

                  ConnectorEndpoint srcCompInfo, Object event)

                  throws ManageException;

     

     

      public List<ComponentConnector> getAllConnectors() throws ManageException;

 

      publicvoid addConnector(ComponentConnector connector) throws ManageException;

 

      publicvoid removeConnector(ComponentConnector connector) throws ManageException;

 

}

 

 

有这样一个最核心的实现：

 

publicclass ManagerImpl implements CoreManager {

 

      privatefinal TargetServerCore TargetServer;

 

      privatestaticfinal Log log = LogFactory.getLog( ManagerImpl.class );

 

      public ManagerImpl(TargetServerCore TargetServer) {

            this.TargetServer = TargetServer;

<d>