【发布时间】:2020-01-06 03:22:18
【问题描述】:
我想显示 MySQL 数据库中所有以 id = 275 开头的消息。我写了一个我不知道的 curl 请求。可能请求写错了。可能是查询语法出错了——
curl -H "Content-Type: application/json" -d "{ \"messageId\": \"275\" }" localhost:8080/api/unread
但是当我通过命令行运行这个 curl 请求时,它显示了一个错误。
{"timestamp":"2020-01-06T03:13:07.899+0000","status":405,"error":"Method Not Allowed","message":"Request method 'POST' not supported","trace":"org.springframework.web.HttpRequestMethodNotSupportedException: Request method 'POST' not supported\r\n\tat org.springframework.web.servlet.mvc.method.RequestMappingInfoHandlerMapping.handleNoMatch(
我的代码 输入消息类
public class InputMessage {
private long messageId;
public InputMessage(long messageId) {
this.messageId = messageId;
}
public InputMessage() {
}
public long getMessageId() {
return messageId;
}
public void setMessageId(long messageId) {
this.messageId = messageId;
}
}
休息控制器
public class RestController {
@Autowired
TimerTask timerTask;
@Resource
private final MessageService messageService;
public RestController(MessageService messageService) {
this.messageService = messageService;
}
@PostMapping("/api/save")
public MessageStatus saveMessage(@RequestBody Message chatMessage) {
return messageService.add(chatMessage);
}
@GetMapping("/api/last")
public String getLasts() {
return new Gson().toJson(messageService.getLast());
}
@GetMapping("/api/unread")
public void getUnreadMessages() {
timerTask.run();
}
@GetMapping("/api/unread/byid")
public List<Message> getUnreadById(@RequestBody InputMessage message) {
return messageService.getUnreadById(message);
}
消息服务实现
public class MessageServiceImpl implements MessageService {
private final MessageRepository repository;
private final PageRequest lastRequest;
private List<Long> chekedMessages = new ArrayList<>();
@Autowired
public MessageServiceImpl(MessageRepository repository) {
this.repository = repository;
lastRequest = new PageRequest(0, 10, Sort.Direction.DESC, "id");
}
@Override
public MessageStatus add(@RequestBody Message message) {
if(message == null) {
System.out.println("Пришел пустой запрос на сохранение данных");
}
MessageStatus status = new MessageStatus();
try {
repository.save(message);
status.setMessage("Сообщение успешно сохранено");
}
catch (Exception e) {
status.setMessage("Во время сохранения сообщения произошла ошибка");
}
return status;
}
@Override
public List<Message> getAllMessages() {
return repository.findAll();
}
@Override
public List<Message> getLast() {
List<Message> result = repository.findAll(lastRequest).getContent();
return result.stream()
.sorted(Comparator.comparingLong(Message::getId))
.collect(Collectors.toList());
}
@Override
public List<Message> getUnreadById(InputMessage message) {
return repository.getUnreadById(message.getMessageId());
}
@Override
public String getUnreadMessages() {
List<Message> out = new ArrayList<>();
List<Message> unchekedMessages = repository.findAll();
for (Message message: unchekedMessages) {
if (!chekedMessages.contains(message.getId())) {
chekedMessages.add(message.getId());
out.add(message);
}
}
return new Gson().toJson(out);
}
@Override
public void updateMessage(long id, Message message) {
if (repository.findById(id).isPresent()) {
message.setId(id);
repository.save(message);
}
}
【问题讨论】:
-
注意HTTP动词already包含“save”等信息;创建对象的常用 REST 路径就是
POST /objects。
标签: java spring spring-boot curl