1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
package samples.bidbuy;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.Enumeration;
import java.util.Hashtable;
import java.util.Vector;
public class RegistryService {
private static Hashtable registry = new Hashtable();
/**
* Find a named service in a list
* @param list of services
* @param name to search for
* @return service found (or null)
*/
public RegistryService() {
load();
}
public void load() {
try {
FileInputStream fis = new FileInputStream("bid.reg");
ObjectInputStream ois = new ObjectInputStream( fis );
registry = (Hashtable) ois.readObject();
ois.close();
fis.close();
} catch(java.io.FileNotFoundException fnfe){
// nop
} catch(Exception e){
e.printStackTrace();
}
}
public void save() {
try {
FileOutputStream fos = new FileOutputStream("bid.reg");
ObjectOutputStream oos = new ObjectOutputStream( fos );
oos.writeObject( registry );
oos.close();
fos.close();
} catch(Exception e){
e.printStackTrace();
}
}
private Service find(Vector list, String name) {
Enumeration e = list.elements();
while (e.hasMoreElements()) {
Service s = (Service) e.nextElement();
if (s.getServiceName().equals(name)) return s;
}
return null;
}
/**
* Unregister a serivce
* @param server name
*/
public void Unregister(String name) {
Enumeration e1 = registry.keys();
while (e1.hasMoreElements()) {
Vector list = (Vector) registry.get(e1.nextElement());
Enumeration e2 = list.elements();
while (e2.hasMoreElements()) {
Service s = (Service) e2.nextElement();
if (s.getServiceName().equals(name)) {
list.remove(s);
save();
}
}
}
}
/**
* Register a new serivce
* @param server name
* @param url of endpoint
* @param stype
* @param wsdl
*/
public void Register(String name, String url, String stype, String wsdl) {
Vector list = (Vector)registry.get(stype);
if (list == null) registry.put(stype, list=new Vector());
Service service = find(list, name);
if (service==null)
list.add(service=new Service());
service.setServiceName(name);
service.setServiceUrl(url);
service.setServiceType(stype);
service.setServiceWsdl(wsdl);
save();
}
/**
* Return the current list of services as an array
* @param Service Name
* @return List of servers that implement that service
*/
public Service[] Lookup(String stype) {
if (!registry.containsKey(stype)) return new Service[] {};
Vector list = (Vector)registry.get(stype);
Service[] result = new Service[list.size()];
list.copyInto(result);
return result;
}
/*
* Return the current list of services as a string
*/
public String LookupAsString(String stype) {
Service[] services = Lookup(stype);
String result = "";
for (int i=0; i<services.length; i++) {
Service service = services[i];
result += service.getServiceName() + "\t" +
service.getServiceUrl() + "\t" +
service.getServiceType() + "\t" +
service.getServiceWsdl() + "\n";
}
return result;
}
}
|
