package com;
import java.io.FileInputStream;
import java.util.Properties;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.frank.observer.service.ISender;
import com.frank.observer.service.ISubject;
public class MainClass {
/**
* @param args
*/
public static void main(String[] args) {
ApplicationContext context =
new ClassPathXmlApplicationContext("applicationContext.xml");
ISubject subject =
(ISubject)context.getBean("subject");
Properties prop = new Properties();
try {
prop.load(new FileInputStream("src/motor.properties"));
} catch (Exception e) {
return;
}
int cnt = Integer.valueOf((String)prop.get("cnt"));
for(int i = 1;i<=cnt;i++)
subject.addSender((ISender)context.getBean("motor" + i));
//测试方法,正常应用过程中,应该是根据数据的变更改而自动通知的
subject.notifySenders();
}
}