Как добавить порт для веб-сокета? - PullRequest
0 голосов
/ 12 апреля 2019

Я добавил websocket в свое приложение.Чтобы проверить, работает ли он правильно, я должен сделать запрос к конечной точке, поэтому вот проблема, как я могу добавить порт для подключения?

public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/ws://localhost:9009");
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.setApplicationDestinationPrefixes("/app");
    registry.enableSimpleBroker("/topic");
}

}

public class ChatController {
@Autowired
PlanfixService planfixService;

@Autowired
UserService userService;

@MessageMapping("/messageToPlanfix")
@SendTo("/topic/public")
public void sendMessageToPlanfix(@RequestBody PlanfixModel planfixModel) throws IOException, URISyntaxException {
    User dbUser = userService.findUserByUsername(AuthenticationController.selfUserName());
    planfixModel.setContactId(String.valueOf(dbUser.getId()));
    planfixModel.setContactName(dbUser.getFirstName());
    planfixService.save(planfixModel);
    requestToPlanfix(planfixModel);
}

public void requestToPlanfix(@RequestBody PlanfixModel planfixModel) throws IOException, URISyntaxException {
    String postUrl = "https://womanmarathon.planfix.ru/webchat/api/";
    Gson gson = new Gson();
    HttpClient httpClient = HttpClientBuilder.create().build();
    HttpPost post = new HttpPost(postUrl);
    StringEntity postingString = new StringEntity(gson.toJson(planfixModel));//gson.tojson() converts your pojo to json
    post.setEntity(postingString);
    post.setHeader("Content-type", "application/json");
    HttpResponse response = httpClient.execute(post);
}


@RequestMapping(value = "/requestFromPlanfix", method = RequestMethod.POST)
@MessageMapping("/messageFromPlanfix")
@SendTo("/topic/public")
public PlanfixModel requestFromPlanfix(@RequestBody PlanfixModel planfixModel) throws Exception {
    planfixService.save(planfixModel);
    return planfixModel;
}

Нужно добавить порт через application.properties?

}

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...