消息推送系统

public class Message {

private String id;

private String content;

private String sender;

private String receiver;

private LocalDateTime timestamp;

// Getters and Setters

}

public interface MessageService {

void sendMessage(Message message);

List getMessagesForUser(String userId);

void deleteMessage(String messageId);

}

@Service

public class MessageServiceImpl implements MessageService {

private Map> userMessages = new HashMap<>();

@Override

public void sendMessage(Message message) {

userMessages.computeIfAbsent(message.getReceiver(), k -> new ArrayList<>()).add(message);

}

@Override

public List getMessagesForUser(String userId) {

return userMessages.getOrDefault(userId, Collections.emptyList());

}

@Override

public void deleteMessage(String messageId) {

userMessages.values().forEach(messages -> messages.removeIf(m -> m.getId().equals(messageId)));

}

}

@RestController

public class MessageController {

@Autowired

private MessageService messageService;

@PostMapping("/messages")

public ResponseEntity sendMessage(@RequestBody Message message) {

messageService.sendMessage(message);

return ResponseEntity.ok().build();

}

@GetMapping("/users/{userId}/messages")

public ResponseEntity> getMessagesForUser(@PathVariable("userId") String userId) {

List messages = messageService.getMessagesForUser(userId);

return ResponseEntity.ok(messages);

}

培训班排课源码

@DeleteMapping("/messages/{messageId}")

public ResponseEntity deleteMessage(@PathVariable("messageId") String messageId) {

messageService.deleteMessage(messageId);

return ResponseEntity.ok().build();

}

}