반응형
스프링 부트 내장 HornetQ 클러스터가 메시지를 전달하지 않음
HornetQ 서버가 내장된2개의 Spring Boot 어플리케이션의 정적 클러스터를 작성하려고 합니다.하나의 응용 프로그램/서버가 외부 이벤트를 처리하고 메시지 큐로 보낼 메시지를 생성합니다.다른 응용 프로그램/서버는 메시지큐에서 리슨하여 착신 메시지를 처리합니다.두 응용 프로그램 간의 링크는 신뢰할 수 없기 때문에 각 응용 프로그램에서는 로컬/inVM 클라이언트만 사용하여 각 서버에서 메시지를 생성/소비하고 클러스터 내의 다른 서버 큐에 메시지를 전송하는 클러스터링 기능을 사용합니다.
를 사용하고 있습니다.HornetQConfigurationCustomizer으로는 HornetQ밖에 없습니다.InVMConnectorFactory.
이 설정 예에서는 "ServerSend"가 메시지를 생성하는 서버를 가리키고 "ServerReceive"는 메시지를 소비하는 서버를 가리킵니다.
두 응용 프로그램의 pom.xml에는 다음이 포함됩니다.
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-hornetq</artifactId>
</dependency>
<dependency>
<groupId>org.hornetq</groupId>
<artifactId>hornetq-jms-server</artifactId>
</dependency>
DemoHornetqServerSendApplication:
@SpringBootApplication
@EnableScheduling
public class DemoHornetqServerSendApplication {
@Autowired
private JmsTemplate jmsTemplate;
private @Value("${spring.hornetq.embedded.queues}") String testQueue;
public static void main(String[] args) {
SpringApplication.run(DemoHornetqServerSendApplication.class, args);
}
@Scheduled(fixedRate = 5000)
private void sendMessage() {
String message = "Timestamp from Server: " + System.currentTimeMillis();
System.out.println("Sending message: " + message);
jmsTemplate.convertAndSend(testQueue, message);
}
@Bean
public HornetQConfigurationCustomizer hornetCustomizer() {
return new HornetQConfigurationCustomizer() {
@Override
public void customize(Configuration configuration) {
String serverSendConnectorName = "server-send-connector";
String serverReceiveConnectorName = "server-receive-connector";
Map<String, TransportConfiguration> connectorConf = configuration.getConnectorConfigurations();
Map<String, Object> params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, "localhost");
params.put(TransportConstants.PORT_PROP_NAME, "5445");
TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
connectorConf.put(serverSendConnectorName, tc);
Set<TransportConfiguration> acceptors = configuration.getAcceptorConfigurations();
tc = new TransportConfiguration(NettyAcceptorFactory.class.getName(), params);
acceptors.add(tc);
params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, "localhost");
params.put(TransportConstants.PORT_PROP_NAME, "5446");
tc = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
connectorConf.put(serverReceiveConnectorName, tc);
List<String> staticConnectors = new ArrayList<String>();
staticConnectors.add(serverReceiveConnectorName);
ClusterConnectionConfiguration conf = new ClusterConnectionConfiguration(
"my-cluster", // name
"jms", // address
serverSendConnectorName, // connector name
500, // retry interval
true, // duplicate detection
true, // forward when no consumers
1, // max hops
1000000, // confirmation window size
staticConnectors,
true // allow direct connections only
);
configuration.getClusterConfigurations().add(conf);
AddressSettings setting = new AddressSettings();
setting.setRedistributionDelay(0);
configuration.getAddressesSettings().put("#", setting);
}
};
}
}
application.properties(ServerSend):
spring.hornetq.mode=embedded
spring.hornetq.embedded.enabled=true
spring.hornetq.embedded.queues=jms.testqueue
spring.hornetq.embedded.cluster-password=password
DemoHornetqServerReceiveApplication:
@SpringBootApplication
@EnableJms
public class DemoHornetqServerReceiveApplication {
@Autowired
private JmsTemplate jmsTemplate;
private @Value("${spring.hornetq.embedded.queues}") String testQueue;
public static void main(String[] args) {
SpringApplication.run(DemoHornetqServerReceiveApplication.class, args);
}
@JmsListener(destination="${spring.hornetq.embedded.queues}")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
@Bean
public HornetQConfigurationCustomizer hornetCustomizer() {
return new HornetQConfigurationCustomizer() {
@Override
public void customize(Configuration configuration) {
String serverSendConnectorName = "server-send-connector";
String serverReceiveConnectorName = "server-receive-connector";
Map<String, TransportConfiguration> connectorConf = configuration.getConnectorConfigurations();
Map<String, Object> params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, "localhost");
params.put(TransportConstants.PORT_PROP_NAME, "5446");
TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
connectorConf.put(serverReceiveConnectorName, tc);
Set<TransportConfiguration> acceptors = configuration.getAcceptorConfigurations();
tc = new TransportConfiguration(NettyAcceptorFactory.class.getName(), params);
acceptors.add(tc);
params = new HashMap<String, Object>();
params.put(TransportConstants.HOST_PROP_NAME, "localhost");
params.put(TransportConstants.PORT_PROP_NAME, "5445");
tc = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
connectorConf.put(serverSendConnectorName, tc);
List<String> staticConnectors = new ArrayList<String>();
staticConnectors.add(serverSendConnectorName);
ClusterConnectionConfiguration conf = new ClusterConnectionConfiguration(
"my-cluster", // name
"jms", // address
serverReceiveConnectorName, // connector name
500, // retry interval
true, // duplicate detection
true, // forward when no consumers
1, // max hops
1000000, // confirmation window size
staticConnectors,
true // allow direct connections only
);
configuration.getClusterConfigurations().add(conf);
AddressSettings setting = new AddressSettings();
setting.setRedistributionDelay(0);
configuration.getAddressesSettings().put("#", setting);
}
};
}
}
application.properties(ServerReceive):
spring.hornetq.mode=embedded
spring.hornetq.embedded.enabled=true
spring.hornetq.embedded.queues=jms.testqueue
spring.hornetq.embedded.cluster-password=password
양쪽 애플리케이션을 기동하면, 로그 출력에 다음과 같이 표시됩니다.
서버 송신:
2015-04-09 11:11:58.471 INFO 7536 --- [ main] org.hornetq.core.server : HQ221000: live server is starting with configuration HornetQ Configuration (clustered=true,backup=false,sharedStore=true,journalDirectory=C:\Users\****\AppData\Local\Temp\hornetq-data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/largemessages,pagingDirectory=data/paging)
2015-04-09 11:11:58.501 INFO 7536 --- [ main] org.hornetq.core.server : HQ221045: libaio is not available, switching the configuration into NIO
2015-04-09 11:11:58.595 INFO 7536 --- [ main] org.hornetq.core.server : HQ221043: Adding protocol support CORE
2015-04-09 11:11:58.720 INFO 7536 --- [ main] org.hornetq.core.server : HQ221003: trying to deploy queue jms.queue.jms.testqueue
2015-04-09 11:11:59.568 INFO 7536 --- [ main] org.hornetq.core.server : HQ221020: Started Netty Acceptor version 4.0.13.Final localhost:5445
2015-04-09 11:11:59.593 INFO 7536 --- [ main] org.hornetq.core.server : HQ221007: Server is now live
2015-04-09 11:11:59.593 INFO 7536 --- [ main] org.hornetq.core.server : HQ221001: HornetQ Server version 2.4.5.FINAL (Wild Hornet, 124) [c139929d-d90f-11e4-ba2e-e58abf5d6944]
서버 수신:
2015-04-09 11:12:04.401 INFO 4528 --- [ main] org.hornetq.core.server : HQ221000: live server is starting with configuration HornetQ Configuration (clustered=true,backup=false,sharedStore=true,journalDirectory=C:\Users\****\AppData\Local\Temp\hornetq-data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/largemessages,pagingDirectory=data/paging)
2015-04-09 11:12:04.410 INFO 4528 --- [ main] org.hornetq.core.server : HQ221045: libaio is not available, switching the configuration into NIO
2015-04-09 11:12:04.520 INFO 4528 --- [ main] org.hornetq.core.server : HQ221043: Adding protocol support CORE
2015-04-09 11:12:04.629 INFO 4528 --- [ main] org.hornetq.core.server : HQ221003: trying to deploy queue jms.queue.jms.testqueue
2015-04-09 11:12:05.545 INFO 4528 --- [ main] org.hornetq.core.server : HQ221020: Started Netty Acceptor version 4.0.13.Final localhost:5446
2015-04-09 11:12:05.578 INFO 4528 --- [ main] org.hornetq.core.server : HQ221007: Server is now live
2015-04-09 11:12:05.578 INFO 4528 --- [ main] org.hornetq.core.server : HQ221001: HornetQ Server version 2.4.5.FINAL (Wild Hornet, 124) [c139929d-d90f-11e4-ba2e-e58abf5d6944]
, 그렇군요.clustered=true 「」라고 됩니다.false HornetQConfigurationCustomizer효과가 있을 거예요.
이제 Server Send는 콘솔 출력에 다음과 같이 표시됩니다.
Sending message: Timestamp from Server: 1428574324910
Sending message: Timestamp from Server: 1428574329899
Sending message: Timestamp from Server: 1428574334904
그러나 Server Receive에는 아무것도 표시되지 않습니다.
메시지가 ServerSend에서 ServerReceive로 전송되지 않은 것 같습니다.
2개의 Spring Boot 어플리케이션(Client Send 및 Client Receive)을 생성하여 테스트를 더 실시했습니다.이 어플리케이션에는 HornetQ 서버가 내장되어 있지 않고 대신 "네이티브" 서버에 접속되어 있습니다.
양쪽 클라이언트애플리케이션의 pom.xml에는 다음이 포함됩니다.
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-hornetq</artifactId>
</dependency>
Demo Hornetq Client Send Application:
@SpringBootApplication
@EnableScheduling
public class DemoHornetqClientSendApplication {
@Autowired
private JmsTemplate jmsTemplate;
private @Value("${queue}") String testQueue;
public static void main(String[] args) {
SpringApplication.run(DemoHornetqClientSendApplication.class, args);
}
@Scheduled(fixedRate = 5000)
private void sendMessage() {
String message = "Timestamp from Client: " + System.currentTimeMillis();
System.out.println("Sending message: " + message);
jmsTemplate.convertAndSend(testQueue, message);
}
}
application.properties(ClientSend):
spring.hornetq.mode=native
spring.hornetq.host=localhost
spring.hornetq.port=5446
queue=jms.testqueue
Demo Hornetq Client Receive Application:
@SpringBootApplication
@EnableJms
public class DemoHornetqClientReceiveApplication {
@Autowired
private JmsTemplate jmsTemplate;
private @Value("${queue}") String testQueue;
public static void main(String[] args) {
SpringApplication.run(DemoHornetqClientReceiveApplication.class, args);
}
@JmsListener(destination="${queue}")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
application.properties(Client Receive):
spring.hornetq.mode=native
spring.hornetq.host=localhost
spring.hornetq.port=5445
queue=jms.testqueue
콘솔에 다음과 같이 표시됩니다.
ServerRive:
Received message: Timestamp from Client: 1428574966630
Received message: Timestamp from Client: 1428574971600
Received message: Timestamp from Client: 1428574976595
클라이언트 수신:
Received message: Timestamp from Server: 1428574969436
Received message: Timestamp from Server: 1428574974438
Received message: Timestamp from Server: 1428574979446
내가 약면면면면이 ServerSendClientReceive또한 그 시점까지 큐잉된 모든 메시지를 수신하므로 메시지가 단순히 어디론가 사라지거나 다른 곳에서 소비되지 않습니다.
완벽함을 위해 제가 지적한 것은ClientSend로.ServerSend그리고.ClientReceive로.ServerReceive클러스터링과 InVM 클라이언트에 문제가 있는지 확인했지만 두 번 모두 메시지가 수신되었음을 나타내는 출력은 없었습니다.ClientReceive또는ServerReceive.
따라서 내장된 각 브로커에서 직접 연결된 외부 클라이언트로의 메시지 전달은 정상적으로 동작하지만 클러스터 내 브로커 간에 메시지가 전송되지는 않습니다.
이 모든 것이 끝나면 클러스터 내에서 메시지가 전송되지 않는 설정에 문제가 있는 것은 무엇일까요?
http://docs.jboss.org/hornetq/2.2.5.Final/user-manual/en/html/architecture.html#d0e595
HornetQ core는 심플한 POJO 세트로 설계되어 있기 때문에 내부에서 메시징 기능을 필요로 하는 어플리케이션을 가지고 있지만 HornetQ 서버로서 HornetQ 서버를 직접 인스턴스화하여 자신의 어플리케이션에 내장할 수 있습니다.
내장하고 있는 경우는, 서버로서 공개하지 않습니다.각 컨테이너에는 별도의 인스턴스가 있습니다.이는 말벌 2개의 복사본을 시작하고 동일한 큐 이름을 부여하는 것과 같습니다.한쪽은 첫 번째 인스턴스의 해당 큐에 쓰고 다른 한쪽은 두 번째 인스턴스의 큐를 리슨합니다.
이러한 방식으로 앱을 분리하려면 서버 역할을 하는 단일 장소가 있어야 합니다.아마 클러스터링을 원할 겁니다.BTW의 Hornet에만 국한된 것이 아닙니다.이런 무늬는 자주 볼 수 있을 거예요.
필터
package it.unitn.disi.webdev.claudiovigliarolo;
import java.io.IOException;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.io.StringWriter;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
@WebFilter(filterName = "AuthenticationFilter", urlPatterns = { "/*" })
public class AuthenticationFilter implements Filter {
private ServletContext context;
public void init(FilterConfig fConfig) throws ServletException {
this.context = fConfig.getServletContext();
this.context.log("AuthenticationFilter initialized");
}
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
throws IOException, ServletException {
HttpServletRequest req = (HttpServletRequest) request;
HttpServletResponse res = (HttpServletResponse) response;
String uri = req.getRequestURI();
HttpSession session = req.getSession(false);
boolean isLoggedIn = session != null && session.getAttribute("username") != null;
if (!isLoggedIn && !uri.endsWith("start.jsp")) {
res.sendRedirect("start.jsp");
} else {
chain.doFilter(request, response);
}
}
public void destroy() {
// close any resources here
}
}<filter-mapping><filter-name>AuthenticationFilter</filter-name><url-pattern>/*</url-pattern>
</filter-mapping>
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import javax.servlet.FilterConfig;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
@WebServlet(name = "GetItems", urlPatterns = { "/GetItems" })
public class GetItems extends HttpServlet {
String dbURL = "jdbc:derby://localhost:1527/ExamDerbyDB";
String user = "WEBENGINE";
String password = "WEBENGINE";
Connection conn = null;
@Override
public void init() {
try {
Class.forName("org.apache.derby.jdbc.ClientDriver");
conn = DriverManager.getConnection(dbURL, user, password);
} catch (ClassNotFoundException | SQLException ex) {
ex.printStackTrace();
}
}
@Override
public void destroy() {
try {
if (conn != null) {
conn.close();
}
} catch (SQLException ex) {
System.err.println("Database connection problem: can't close connection");
}
}
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
response.setContentType("text/html;charset=UTF-8");
String username = request.getParameter("username");
String password = request.getParameter("password");
StringBuilder ret = new StringBuilder();
ArrayList<String> inserted = getAllItemsFromDB();
String jsonResponse = getListJson(inserted);
response.setContentType("application/json;charset=UTF-8");
try (PrintWriter out = response.getWriter()) {
out.println(jsonResponse);
}
}
private ArrayList<String> getAllItemsFromDB() throws ServletException {
ArrayList elements = new ArrayList();
PreparedStatement stm = null;
ResultSet result = null;
try {
String query = "SELECT USERNAME FROM USERS";
stm = conn.prepareStatement(query);
result = stm.executeQuery();
while(result.next()) {
String string = result.getString(1);
elements.add(string);
}
stm.close();
result.close();
} catch (SQLException ex) {
System.err.println("Database connection problem");
} finally {
try {
if(stm != null) stm.close();
if(result != null) result.close();
} catch (SQLException ex) {
System.err.println("Database connection problem: can't close statement/result");
}
return elements;
}
public String getListJson(ArrayList<String> list) {
if (list.size() == 0)
return null;
StringBuilder ret = new StringBuilder("[");
String prefix = "";
for (int i = 0; i < list.size(); i++) {
StringBuilder sb = new StringBuilder();
ret.append(prefix);
prefix = ",";
ret.append(sb.append("{\"message\":\"").append(list.get(i)).append("\"}").toString());
}
ret.append("]");
return ret.toString();
}
}
class.class.class.class.class.
public class MessageList {
protected final LinkedList<Message> list;
public MessageList() {
this.list = new LinkedList<>();
}
public void addMessage(Message m) {
this.list.add(m);
}
public void deleteMessage(String message_id) {
for (Message a : list) {
if (a.message_id.equals(message_id)) {
list.remove(a);
}
}
}
public Message getMessage(String message_id) {
for (Message a : list) {
if (a.message_id.equals(message_id)) {
return a;
}
}
return null;
}
public void addLike(String message_id) {
for (Message a : list) {
if (a.message_id.equals(message_id)) {
a.isLiked++;
}
}
}
StringBuilder ret = new StringBuilder("[");
String prefix = "";for(
int i = 0;i<list.size();i++)
{
Message m = list.get(i);
ret.append(prefix);
prefix = ",";
ret.append(m.toJson());
}ret.append("]");
return ret.toString();
}
public String getListJson()
{
if(list.size() == 0)
{
return null;
}
StringBuilder ret = new StringBuilder("[");
String prefix = "";
for(int i=0; i<list.size(); i++) {
StringBuilder sb = new StringBuilder();
ret.append(prefix);
prefix = ",";
ret.append(sb.append("{\"message\":\"").append(list.get(i)).append("\"}").toString());
}
ret.append("]");
return ret.toString();
}
}
형태
<!DOCTYPE html>
<html lang="en">
<body>
<script>
function validateForm(form) {
var username = document.getElementById("username").value;
var password = document.getElementById("password").value;
var error = document.getElementById("error");
error.innerHTML = "";
if (username === "" || password == "") {
form.reset();
error.innerHTML = "password / username empty";
return false;
}
return true;
}
</script>
<div class="container" style="width: 500px; float: left">
<h2 class="text-center">Welcome to the App</h2>
<form
id="registerForm"
method="POST"
onsubmit="return validateForm(this)"
action="Registration"
>
<div class="form-group">
<label for="username">Username:</label>
<input
type="text"
class="form-control"
id="username"
placeholder="Enter email"
name="username"
/>
</div>
<div class="form-group">
<label for="password">Password:</label>
<input
type="password"
class="form-control"
id="password"
placeholder="Enter password"
name="password"
/>
</div>
<div class="form-group form-check"></div>
<button type="submit" class="btn btn-primary">Submit</button>
</form>
<div id="error" class="alert" role="alert"></div>
</div>
</body>
</html>
일반적인
//servelet context
ServletContext application=getServletContext();
application.setAttribute("messages", messages);
//SESSION
HttpSession session = request.getSession();
String name = (String) request.getParameter("username");
session.setAttribute("username", name);
//random id java
String uniqueID = UUID.randomUUID().toString();
//package
it.unitn.disi.webdev.claudiovigliarolo
//project name
VIGLIAROLO_C_202314
//get contextpath
String contextPath = request.getContextPath();
System.out.println("Context Path = " + contextPath);
response.sendRedirect(contextPath + "/main.html");
//BOOTstrap
<head>
<title>Bootstrap Example</title>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/4.5.2/css/bootstrap.min.css">
<script src="https://ajax.googleapis.com/ajax/libs/jquery/3.5.1/jquery.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/popper.js/1.16.0/umd/popper.min.js"></script>
<script src="https://maxcdn.bootstrapcdn.com/bootstrap/4.5.2/js/bootstrap.min.js"></script>
</head>
//redirect to other page
window.location.replace("http://stackoverflow.com");
//CONTENT type
response.setContentType("application/json;charset=UTF-8");
response.setContentType("text/html;charset=UTF-8");
//zuccherino
protected final LinkedList<Message> list;
public MessageList() {
this.list = new LinkedList<>();
}
<!DOCTYPE html>
<html lang="en">
<body>
<script>
function validateForm(form) {
var username = document.getElementById("username").value;
var password = document.getElementById("password").value;
var error = document.getElementById("error");
error.innerHTML = "";
if(username === "" || password == "") {
form.reset();
error.innerHTML = "password / username empty";
return false;
}
return true;
}
</script>
<div class="container " style="width:500px; float: left;">
<h2 class="text-center">Welcome to the App</h2>
<form id="registerForm" method="POST" onsubmit="return validateForm(this)" action="Registration">
<div class="form-group">
<label for="username">Username:</label>
<input type="text" class="form-control" id="username" placeholder="Enter email" name="username">
</div>
<div class="form-group">
<label for="password">Password:</label>
<input type="password" class="form-control" id="password" placeholder="Enter password" name="password">
</div>
<div class="form-group form-check">
</div>
<button type="submit" class="btn btn-primary">Submit</button>
</form>
<div id="error" class="alert" role="alert">
</div>
</div>
</body>
</html>
//change styles
const val = keywords.some(k=>item.message.includes(k));
const color = val ? "#FFFF00;" : "transparent;";
document.getElementById("data").innerHTML +=
"<div style=' margin-top:50px;flexdirection: row; display:flex; width:500px; background:" + color + "; justify-content: row; '>" +
item.message +
"</div>";
//setimeout
function refresh() {
// make Ajax call here, inside the callback call:
setTimeout(refresh, 5000);
// ...
}
// initial call, or just call refresh directly
setTimeout(refresh, 5000);
//template strings
`string text`
getclaudio 후음
<script>
function onSendData() {
var title = document.getElementById("username").value;
var description = document.getElementById("password").value;
console.log(title, description);
var http = new XMLHttpRequest();
var url = "Registration";
var params = "password=" + description + "&username=" + title;
http.open("POST", url, true);
//Send the proper header information along with the request
http.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
http.onreadystatechange = function () {
//Call a function when the state changes.
if (http.readyState == 4 && http.status == 200) {
console.log("res", http.responseText);
}
};
http.send(params);
}
</script>
------GET---------------
//loadData noparam
<script>
loadData();
function loadData() {
var xhttp = new XMLHttpRequest();
xhttp.open("GET", "GetProducts", true);
xhttp.responseType = "json";
xhttp.onreadystatechange = function () {
var done = 4,
ok = 200;
if (this.readyState === done && this.status === ok) {
my_JSON_object = this.response;
console.log("response", my_JSON_object);
document.getElementById("data").innerHTML = "";
my_JSON_object && my_JSON_object.forEach((item) => {
console.log("item", item.message);
document.getElementById("data").innerHTML +=
" <div class='card' style='width: 300px; margin-top:50px;'>" +
"<div class='card-body'>" +
" <h4 class='card-title'>" + item.name + "</h4>" +
"<p class='card-text'>" + item.description + "</p>" +
" <p class='card-text'>Price: " + item.price + " $</p>" +
" <a href='detail.html?name=" + item.name + "' class='card-link' >View details</a>" +
" </div> </div>";
});
}
};
xhttp.send();
}
</script>
<div id="data"></div>
//loadData withparam
<script>
function getData() {
const urlParams = new URLSearchParams(window.location.search);
const id = urlParams.get('id');
const id2 = urlParams.get('id2');
console.log(id)
var url = "GetItems";
let param1 = id;
let param2 = id2;
var params = "param1=" + param1 + "¶m2=" + param2;
var http = new XMLHttpRequest();
http.open("GET", url + "?" + params, true);
http.responseType = "json";
http.onreadystatechange = function () {
var done = 4,
ok = 200;
if (this.readyState === done && this.status === ok) {
my_JSON_object = this.response;
console.log("response", my_JSON_object);
document.getElementById("data").innerHTML = "";
my_JSON_object && my_JSON_object.forEach((item) => {
console.log("item", item.message);
document.getElementById("data").innerHTML +=
"<div style=' margin-top:50px;flexdirection: row; display:flex; width:500px; justify-content: row; '>" +
item.message +
"</div>";
});
}
};
http.send(null);
}
</script>
<div id="data"></div>
<div class="card" style="margin-top: 50px;">
<div class="card-body">Content</div>
</div>
//render multiple parameters
onclick="showData('${item.name}', '${item.price}', '${item.punteggio}', '${item.extra}' )"
JSON servlet claudio
RETURN JSON
//create simple json response
response.setContentType("application/json;charset=UTF-8");
StringBuilder ret = new StringBuilder();
ret.append("{\"ready\":\"").append("false").append("\"}");
try (PrintWriter out = response.getWriter()) {
out.println(ret.toString());
}
JSON LIST CLASS
public String toJSON() {
StringBuilder ret = new StringBuilder("[");
String prefix = "";
for(int i=0; i<list.size(); i++) {
Message m = list.get(i);
ret.append(prefix);
prefix = ",";
ret.append(m.toJson());
}
ret.append("]");
System.err.println("priting tojson"+ ret.toString());
return ret.toString();
}
JSON ITEM
public String toJson() {
StringBuilder ret = new StringBuilder();
ret.append("{\"id\":\"").append(this.id).append("\",");
ret.append("\"nome\":\"").append(this.nome).append("\",");
ret.append("\"imgName\":\"").append(this.imgName).append("\"}");
return ret.toString();
}
STRING LIST
public String wordsToJSON(ArrayList<String> list) {
System.err.println("lunghezza" + list.size());
if (list.size() == 0) {
return null;
}
StringBuilder ret = new StringBuilder("[");
String prefix = "";
for (int i = 0; i < list.size(); i++) {
StringBuilder sb = new StringBuilder();
ret.append(prefix);
prefix = ",";
ret.append(sb.append("{\"message\":\"").append(list.get(i)).append("\"}").toString());
}
ret.append("]");
System.err.println("jjj" + ret.toString());
return ret.toString();
}
}
JSON RESPONSE OK
ServletContext application=getServletContext();
MappaDiCoppie mappaDiCoppie = (MappaDiCoppie) application.getAttribute("mappaDiCoppie");
HttpSession session= request.getSession();
String username = (String) session.getAttribute("username");
StringBuilder ret = new StringBuilder();
if(mappaDiCoppie != null && username != null)
{
if(mappaDiCoppie.exists(username))
//ok
ret.append("{\"ready\":\"").append("true").append("\"}");
else
//no wait
ret.append("{\"ready\":\"").append("false").append("\"}")
try (PrintWriter out = response.getWriter()) {
out.println(ret.toString());
}
}
```
스타일시트
<link rel="stylesheet" href="./styles/styles.css">
<script type="text/javascript" src="./js/script.js"></script>
매트릭스 html
const N = 9;
const container = document.getElementById("container");
function makeRows(rows, cols) {
container.style.setProperty('--grid-rows', rows);
container.style.setProperty('--grid-cols', cols);
for (c = 0; c < (cols); c++) {
for (r = 0; r < rows; r++) {
const myid = JSON.stringify({x: r, y: c});
let cell = document.createElement("div");
var textnode = document.createElement("span");
textnode.setAttribute("id", myid);
cell.appendChild(textnode);
cell.onclick = function (event) {
showVal(myid, r, c);
}
//cell.innerText = (c + 1);
container.appendChild(cell).className = "grid-item";
container.appendChild(cell).style = "border-color: red";
container.appendChild(cell).style = "border-width: 4px";
}
;
}
}
//styles
.myinput{
width: 50px;
margin-right: 20px;
}
#container {
display: grid;
grid-gap: .5em;
grid-template-rows: repeat(var(--grid-rows), 1fr);
grid-template-columns: repeat(var(--grid-cols), 1fr);
width: 100px;
}
.grid-item {
border: 1px solid #ddd;
text-align: center;
width: 50px;
height: 50px;
border-width: 2px;
border-color: green;
}
그리드 자바
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package utils;
import java.util.ArrayList;
import java.util.Random;
/**
*
* @author claud
*/
public class Grid {
int N;
Cell[][] matrix;
public Grid(int N) {
this.N = N;
this.matrix = new Cell[N][N];
}
private int getRandom() {
Random rn = new Random();
int range = 0 - 0 + 1;
int randomNum = rn.nextInt(N) + 0;
return randomNum;
}
public int getValue(int x, int y) {
if (x < N && y < N) {
return this.matrix[x][y].value;
} else {
return -2;
}
}
public void generate() {
System.err.println("ffffffffffffggg");
//fai il ciclo completo
for (int i = 0; i < N; i++) {
for (int j = 0; j < N; j++) {
this.matrix[i][j] = new Cell(i, j, 0);//aggiungi bombe con random altrimenti valore 0
}
}
}
public void print() {
System.err.println("printiiiiiiiiiiiing START");
for (int i = 0; i < N; i++) {
for (int j = 0; j < N; j++) {
System.err.println(this.matrix[i][j].value);
}
}
}
}
언급URL : https://stackoverflow.com/questions/29536499/spring-boot-embedded-hornetq-cluster-not-forwarding-messages
반응형
'programing' 카테고리의 다른 글
| Python에서 "named tuples"는 무엇입니까? (0) | 2022.09.04 |
|---|---|
| $(표준)jQuery를 사용하지 않는 ready 등가물 (0) | 2022.09.04 |
| SHOW PROCESS LIST에서 전체 쿼리를 표시하는 방법 (0) | 2022.09.04 |
| Java 한 문자열에서 여러 개의 서로 다른 서브스트링을 동시에 치환(또는 가장 효율적인 방법으로) (0) | 2022.09.04 |
| 봄철 @Component, @Repository 및 @Service 주석의 차이점은 무엇입니까? (0) | 2022.09.01 |