| from dubbo_client import ZookeeperRegistry, MulticastRegistry, Registry |
| |
| __author__ = 'caozupeng' |
| |
| |
| def multicat(): |
| registry = MulticastRegistry('224.5.6.7:1234') |
| registry.subscribe('com.ofpay.demo.api.UserProvider') |
| print registry.get_provides('com.ofpay.demo.api.UserProvider') |
| |
| |
| def zookeeper(): |
| registry = ZookeeperRegistry('172.19.65.33:2181') |
| registry.subscribe('com.ofpay.demo.api.UserProvider') |
| print registry.get_provides('com.ofpay.demo.api.UserProvider') |
| |
| |
| def test_registry(): |
| registry = Registry() |
| registry._add_node("com.ofpay.demo.api.UserProvider", |
| "jsonrpc://192.168.2.1:38081/com.ofpay.demo.api.UserProvider2?" |
| "anyhost=true&application=jsonrpcdemo&default.timeout=10000&" |
| "dubbo=2.4.10&environment=product&interface=com.ofpay.demo.api.UserProvider&" |
| "methods=getUser,queryAll,isLimit,queryUser&owner=wenwu&pid=60402&revision=2.0&" |
| "side=provider×tamp=1429105028153&version=2.0") |
| registry._add_node("com.ofpay.demo.api.UserProvider", |
| "jsonrpc://192.168.2.1:38081/com.ofpay.demo.api.UserProvider?" |
| "anyhost=true&application=jsonrpcdemo&default.timeout=10000&" |
| "dubbo=2.4.10&environment=product&interface=com.ofpay.demo.api.UserProvider&" |
| "methods=getUser,queryAll,isLimit,queryUser&owner=wenwu&pid=60402&revision=2.0&" |
| "side=provider×tamp=1429105028153&version=1.0") |
| assert registry._service_provides |
| |
| |
| if __name__ == '__main__': |
| multicat() |
