집 > 기사 > 웹 프론트엔드 > 30분 만에 리버스 Ajax 마스터하기

30분 만에 리버스 Ajax 마스터하기

亚连원래의: 2018-05-23 15:49:481517검색

이 글은 30분 안에 빠르게 마스터할 수 있는 Reverse Ajax에 대한 관련 정보를 주로 소개합니다. 필요하신 분들은 참고하시면 됩니다.

시나리오 1: 새 이메일이 오면 웹페이지에서 자동으로 프롬프트 메시지가 뜹니다. 사용자가 받은 편지함을 수동으로 새로 고쳐야 합니다.

시나리오 2: 사용자의 휴대폰이 페이지의 QR 코드를 스캔하면 페이지가 자동으로 이동합니다.

시나리오 3: 채팅방과 같은 환경에서 누군가가 말을 하면, 로그인한 모든 사용자는 즉시 메시지를 볼 수 있습니다.

요청이 클라이언트에서 시작되고 서버에서 응답해야 하는 기존 MVC 모델과 비교할 때, 역방향 Ajax를 사용하면 서버가 이벤트를 클라이언트에 적극적으로 푸시하여 사용자 경험을 향상시키는 것을 시뮬레이션할 수 있습니다. 이 기사에서는 역방향 Ajax 기술을 Comet과 WebSocket의 두 부분으로 나누어 설명합니다. 이 기사에서는 위의 두 가지 기술적 수단을 구현하는 방법을 시연하는 것을 목표로 하며 Struts2 또는 SpringMVC의 애플리케이션은 다루지 않습니다. 또한 Servlet 구성에서도 Annotation을 사용하여 관련 지식을 얻을 수 있으며, 다른 자료를 참조할 수도 있습니다.

1. Comet(최고의 호환성 방법)

Comet은 본질적으로 서버에서 클라이언트로 데이터를 보낼 수 있다는 개념입니다. 표준 HTTP Ajax 요청에서 데이터는 서버로 전송됩니다. Reverse Ajax는 특정 방식으로 Ajax 요청 생성을 시뮬레이션하므로 서버는 가능한 한 빨리 클라이언트에 이벤트를 보낼 수 있습니다. 일반 HTTP 요청에는 종종 페이지 이동이 수반되고 푸시 이벤트를 수행하려면 브라우저가 동일한 페이지나 프레임에 있어야 하므로 Comet 구현은 Ajax를 통해서만 완료될 수 있습니다.

구현 프로세스는 다음과 같습니다. 페이지가 로드되면 Ajax 요청이 서버로 전송되고, 서버는 요청을 받아 스레드로부터 안전한 컨테이너(일반적으로 대기열)에 저장합니다. 동시에 서버는 다른 요청에도 정상적으로 응답할 수 있습니다. 푸시해야 할 이벤트가 도착하면 서버는 컨테이너의 요청을 순회하고 응답을 반환한 후 삭제합니다. 그런 다음 페이지에 있는 모든 브라우저는 응답을 받고 Ajax 요청을 다시 보내며 위 프로세스를 반복합니다.

<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme() + "://" + request.getServerName() + ":" + request.getServerPort()
+ path + "/";
%>
<!DOCTYPE html>
<html lang="en">
<base href="<%=basePath%>">
<head>
<title>WebSocket</title>
<script type="text/javascript" src="static/jquery-1.9.1.min.js"></script>
<script type="text/javascript">
$(function() {
connect();
$("#btn").click(function() {
var value = $("#message").val();
$.ajax({
url : "longpolling?method=onMessage&msg=" + value,
cache : false,
dataType : "text",
success : function(data) {
}
});
});
});
function connect() {
$.ajax({
url : "longpolling?method=onOpen",
cache : false,
dataType : "text",
success : function(data) {
connect();
alert(data);
}
});
}
</script>
</head>
<body>
<h1>LongPolling</h1>
<input type="text" id="message" />
<input type="button" id="btn" value="发送" />
</body>
</html>

BTN에서 보낸 요청에는 실제로 응답을 받을 필요가 없다는 사실을 확인했습니다. 전체 프로세스의 핵심은 클라이언트가 항상 서버에 연결() 요청을 유지한다는 것입니다. 서버 측에서는 먼저 이 비동기 응답 방법을 지원해야 합니다. 다행히 지금까지 대부분의 서블릿 컨테이너는 좋은 지원을 제공했습니다. 아래에서 Tomcat을 예로 들어 보겠습니다.

package servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import javax.servlet.AsyncContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@WebServlet(value="/longpolling", asyncSupported=true)
public class Comet extends HttpServlet {
private static final Queue<AsyncContext> CONNECTIONS = new ConcurrentLinkedQueue<AsyncContext>();
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String method = req.getParameter("method");
if (method.equals("onOpen")) {
onOpen(req, resp);
} else if (method.equals("onMessage")) {
onMessage(req, resp);
}
}
private void onOpen(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
AsyncContext context = req.startAsync();
context.setTimeout(0);
CONNECTIONS.offer(context);
}
private void onMessage(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String msg = req.getParameter("msg");
broadcast(msg);
}
private synchronized void broadcast(String msg) {
for (AsyncContext context : CONNECTIONS) {
HttpServletResponse response = (HttpServletResponse) context.getResponse();
try {
PrintWriter out = response.getWriter();
out.print(msg);
out.flush();
out.close();
context.complete();
CONNECTIONS.remove(context);
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

ConcurrentLinkedQueue는 요청을 저장하기 위한 컨테이너로 사용되는 대기열 대기열의 스레드로부터 안전한 구현입니다. AsyncContext는 Tomcat에서 지원하는 비동기 환경이며 서버마다 약간 다른 개체를 사용합니다. Jetty가 지원하는 객체는 Continuation입니다. 브로드캐스트가 완료된 요청은 context.complete()를 통해 해당 요청을 종료해야 하며, CONNECTIONS.remove(context)를 사용하여 큐를 삭제해야 합니다.

2. WebSocket(HTML5에서 지원)

HTTP 롱 폴링을 사용하는 Comet은 이제 모든 브라우저가 이를 지원하므로 역방향 Ajax를 안정적으로 구현하는 가장 좋은 방법입니다.

WebSocket은 HTML5에 등장했으며 Comet보다 새로운 역방향 Ajax 기술입니다. WebSocket은 양방향 전이중 통신 채널을 지원하며 많은 브라우저(Firefox, Google Chrome 및 Safari)도 이를 지원합니다. 연결은 HTTP 요청(WebSocket 핸드셰이크라고도 함)과 일부 특수 헤더를 통해 이루어집니다. 연결은 항상 활성화되어 있으며 원시 TCP 소켓과 마찬가지로 JavaScript로 데이터를 쓰고 받을 수 있습니다.

ws:// 또는 wss://(SSL의 경우)를 입력하여 WebSocket URL을 시작하세요. 그림에 표시된 대로:

우선: WebSocket은 모든 브라우저에서 잘 지원되지 않으며 분명히 IE는 주저하고 있습니다. 따라서 이 기술을 사용하려는 경우 사용자의 사용 환경을 고려해야 합니다. 프로젝트가 인터넷을 대상으로 하거나 휴대폰 사용자를 포함하는 경우 모든 사람에게 다시 한 번 생각해 보시기 바랍니다.

두 번째: WebSocket이 제공하는 요청은 일반 HTTP 요청과 다릅니다. 이는 전이중 통신이며 항상 활성화되어 있습니다(끄지 않는 경우). 즉, 응답을 받을 때마다 다시 서버에 요청을 보낼 필요가 없으므로 많은 리소스를 절약할 수 있습니다.

<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme() + "://" + request.getServerName() + ":" + request.getServerPort()
+ path + "/";
String ws = "ws://" + request.getServerName() + ":" + request.getServerPort() + path + "/";
%>
<!DOCTYPE html>
<html lang="en">
<base href="<%=basePath%>">
<head>
<title>WebSocket</title>
<script type="text/javascript" src="static/jquery-1.9.1.min.js"></script>
<script type="text/javascript">
$(function() {
var websocket = null;
if ("WebSocket" in window){
websocket = new WebSocket("<%=ws%>websocket");
} else {
alert("not support");
}
websocket.onopen = function(evt) {
}
websocket.onmessage = function(evt) {
alert(evt.data);
}
websocket.onclose = function(evt) {
}
$("#btn").click(function() {
var text = $("#message").val();
websocket.send(text);
});
});
</script>
</head>
<body>
<h1>WebSocket</h1>
<input type="text" id="message" />
<input type="button" id="btn" value="发送"/>
</body>
</html>

JQuery는 아직 WebSocket에 대한 더 나은 지원을 제공하지 않으므로 코드의 일부를 작성하려면 Javascript를 사용해야 합니다(다행히 복잡하지는 않습니다). 그리고 일부 일반 서버는 Tomcat을 예로 들어 ws 요청을 지원할 수 있습니다. 버전 6.0에서는 WebSocketServlet 객체가 @java.lang.Deprecated로 표시되었습니다. 7.0 이후 버전에서는 jsr365에서 제공하는 구현을 지원하므로 관련 구성을 완료하려면 주석을 사용해야 합니다.

package servlet;
import java.io.IOException;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/websocket")
public class WebSocket {
private static final Queue<WebSocket> CONNECTIONS = new ConcurrentLinkedQueue<WebSocket>();
private Session session;
@OnOpen
public void onOpen(Session session) {
this.session = session;
CONNECTIONS.offer(this);
}
@OnMessage
public void onMessage(String message) {
broadcast(message);
}
@OnClose
public void onClose() {
CONNECTIONS.remove(this);
}
private synchronized void broadcast(String msg) {
for (WebSocket point : CONNECTIONS) {
try {
point.session.getBasicRemote().sendText(msg);
} catch (IOException e) {
CONNECTIONS.remove(point);
try {
point.session.close();
} catch (IOException e1) {
}
}
}
}
}

3. 요약(요청부터 푸시까지)

전통적인 통신 방식에서는 시스템 A가 시스템 B의 정보가 필요한 경우 시스템 B에 요청을 보냅니다. 시스템 B는 요청을 처리하고 시스템 A는 응답을 기다립니다. 처리가 완료되면 응답이 시스템 A로 다시 전송됩니다. 동기식 통신 모드에서는 응답을 기다리는 데 처리 시간이 낭비되기 때문에 자원 사용 효율성이 떨어집니다.

비동기 모드에서 시스템 A는 시스템 B에서 얻고자 하는 정보를 구독합니다. 그런 다음 시스템 A는 시스템 B에 알림을 보내거나 정보를 즉시 반환할 수 있으며 시스템 A는 다른 트랜잭션을 처리할 수 있습니다. 이 단계는 선택 사항입니다. 이벤트 기반 애플리케이션에서는 일반적으로 해당 이벤트가 무엇인지 모르기 때문에 다른 시스템에 이벤트 전송을 요청할 필요가 없습니다. 시스템 A는 시스템 B가 응답을 게시한 후 즉시 응답을 받습니다.

웹 프레임워크는 전통적인 "요청-응답" 모델에 의존하여 페이지를 새로 고쳤습니다. Ajax, Reverse Ajax 및 WebSocket의 출현으로 이제 이벤트 중심 아키텍처의 개념을 웹에 쉽게 적용하여 분리, 확장성 및 반응성의 이점을 얻을 수 있습니다. 더 나은 사용자 경험은 새로운 비즈니스 기회도 가져올 것입니다.

위 내용은 제가 여러분을 위해 정리한 내용입니다. 앞으로 도움이 되길 바랍니다.

30분 만에 리버스 Ajax 마스터하기

관련 기사