基于RMI的分布式议程服务

package bupt.sse.wenfeng.service; import java.rmi.RemoteException; import java.rmi.server.UnicastRemoteObject; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; @SuppressWarnings("serial") public class Implement extends UnicastRemoteObject implements Interface{ private List<User> users=null; private List<Meeting> meets=null; private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); protected Implement() throws RemoteException { super(); // TODO Auto-generated constructor stub users = new ArrayList<User>(); meets = new ArrayList<Meeting>(); } @Override public boolean register(String userName, String password) throws RemoteException { // TODO Auto-generated method stub for(User u:users){ if(u.getName().equals(userName)){ System.out.println("该用户已经被注册，请重新输入"); return false; } } User u = new User(userName,password); users.add(u); System.out.println("注册成功！"); return true; } @Override public boolean add(String userName, String password, String schedule_user, String title, String label, Date startTime, Date endTime) throws RemoteException { // TODO Auto-generated method stub if(!hasUser(userName)){ System.out.println("未查到对方用户存在！创建会议失败"); return false; } if(startTime.after(endTime)||endTime.before(startTime)){ System.out.println("时间区间不合理，请重新安排！"); return false; } for(Meeting m : meets){ if(m.getUser().getName().equals(userName) ||m.getUser().getName().equals(schedule_user) ||m.getOtherUserName().equals(userName) ||m.getOtherUserName().equals(schedule_user)){ if(!(startTime.after(m.getEndTime()) || endTime .before(m.getStartTime()))){ System.out.println("该时间段，参会用户发生时间冲突，添加会议失败！"); return false; } } } User user = new User(userName, password); Meeting meeting = new Meeting(startTime, endTime, label, title, schedule_user, user); meets.add(meeting); System.out.println("增加会议成功！会议ID：" + meeting.getMeetingID()); return true; } @Override public String query(String userName, Date start, Date end) throws RemoteException { // TODO Auto-generated method stub String str = ""; int count = 0; for(Meeting m: meets){ if ((m.getUser().getName().equals(userName) || m .getOtherUserName().equals(userName))) { if ((m.getStartTime().after(start) && m.getEndTime() .before(end)) || (m.getStartTime().equals(start) && m .getEndTime().equals(end)) || (m.getStartTime().equals(start) && m .getEndTime().before(end)) || (m.getStartTime().after(start) && m .getEndTime().equals(end))) { str += "会议" + (++count) + ":时间从" + format.format(m.getStartTime()) + "到" + format.format(m.getEndTime()) + "\n\t题目为" + m.getTitle() + "\n\t标注为" + m.getLabel() + "\n"; //System.out.println(str); } } } return str; } @Override public boolean delete(String userName, int meetingID) throws RemoteException { // TODO Auto-generated method stub for(Meeting m : meets){ if(m.getMeetingID()==meetingID){ if(m.getUser().getName().equals(userName)|| m.getOtherUserName().equals(userName)){ meets.remove(m); System.out.println("该会议已经成功删除！"); return true; } else{ System.out.println("您不是该会议的参会人员，不具有权限删除该会议！"); return false; } } } System.out.println("未查询到该会议！"); return false; } @Override public void clear(String userName) throws RemoteException { // TODO Auto-generated method stub for(Meeting m:meets){ if(m.getUser().getName().equals(userName) ||m.getOtherUserName().equals(userName)){ meets.remove(m); } } } public boolean hasUser(String userName){ for(User u: users){ if(u.getName().equals(userName)) return true; } return false; } }