How to test servlet using Telnet

Essentially what I need to do is just make an HTTP Call using Telnet.

$> telnet 127.0.0.1 9086

Ok, I'm connected, and now what??
I know which servlet I want to test, I know which parameters is expecting, then "let's do it":

Which method should I use? POST or GET?? let's use POST (due to well known limitations with GET)

This is my URL:

/MyWebApp/proxyServlet?operation=doSomethingNice&consumerName=myActiveMQConsumers&server=192.168.5.122:9080&targetServlet=/MyOtherWebApp/utilsServlet

I'll finish my command with the HTTP version I want to use: HTTP/1.0 (if I use 1.1 it'll keep you connected)

And finally let's put all together:
POST /MyWebApp/proxyServlet?operation=doSomethingNice&consumerName=myActiveMQConsumers&server=192.168.5.122:9080&targetServlet=/MyOtherWebApp/utilsServlet HTTP/1.0
Important: Once you have copied this full line in your telnet body, please type ENTER twice.

How do I know if this works? You should see this on your telnet console:

HTTP/1.0 200 OK
Content-Type: text/xml;charset=ISO-8859-1
Cache-Control: no-cache
Content-Language: en-US
Content-Length: 21
Date: Thu, 19 Aug 2010 18:38:45 GMT
Server: WebSphere Application Server/6.1

true

Connection to host lost.

Small Proxy App based on Apache Mina 2.0.0-RC1

What I'm going to do is develop a small app which basically is going to broadcast a message received to another host in a defined port.
My small app is just a standalone app based on Apache Mina, is going to be listening on "X" port and it's going to broadcast message received to another app which is a blackbox. So simple, Isn't it?


What do you need?

• mina-filter-compression-2.0.0-RC1.jar
• mina-integration-xbean-2.0.0-RC1.jar
• slf4j-log4j12-1.5.0.jar
• mina-integration-beans-2.0.0-RC1.jar
• jzlib-1.0.7.jar
• jaxen-1.1.1.jar
• mina-transport-apr-2.0.0-RC1.jar
• log4j-1.2.15.jar
• slf4j-api-1.5.0.jar
• mina-core-2.0.0-RC1.jar

Or simple, you can get the full distribution and get them all in one single file.
This jar is just a luxury, but it's necesary, because I don't want to reinvent the wheel: commons-lang-2.3.jar

Well, time to work, the first thing you should code is the main class, my ProxyServer and 2 IoHandlers (ProxyHandlerAdapter & ClientHandlerAdapter).

And this is my code
public class GSBProxyServer { private static Logger logger = Logger.getLogger(GSBProxyServer.class); private int initPoolSize = Runtime.getRuntime().availableProcessors()+1; private int maxPoolSize = 20; private int keepAliveTimeInSecs = 10;//for each thread in our pool private static SocketAcceptor acceptor; private static ExecutorService executor; public GSBProxyServer(){ LogUtils.initialize(); if(logger.isInfoEnabled()){ logger.info("GSB TCP Proxy server starting."); } try { if(logger.isDebugEnabled()){ logger.debug("loding properties file."); } ReceiverFactory.load(Constants.PROPERTIES_FILE); } catch (Exception e) { e.printStackTrace(); logger.error("Tcp Receiver factory load failed."); System.exit(-1); } IoBuffer.setUseDirectBuffer(false);//switch the default buffer type to 'heap' IoBuffer.setAllocator(new SimpleBufferAllocator()); //IoBuffer.setAllocator(new CachedBufferAllocator()); executor = new OrderedThreadPoolExecutor(initPoolSize, maxPoolSize, keepAliveTimeInSecs, TimeUnit.SECONDS);//Ordered/UnorderedThreadPoolExecutor has prevention mechanism against OutOfMemoryError, so you will prefer these two classes to other Executor implementations probably. acceptor = new NioSocketAcceptor(initPoolSize); acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8")))); acceptor.getFilterChain().addLast("threadPool", new ExecutorFilter(executor)); //acceptor.getSessionConfig().setReadBufferSize(2048);//by default is 2048 acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 1); acceptor.getSessionConfig().setTcpNoDelay(true); try { acceptor.setHandler(new ProxyHandlerAdapter()); acceptor.bind(new InetSocketAddress(Constants.PORT_NUMBER)); if(logger.isInfoEnabled()){ logger.info("GSB TCP Proxy server started. Listening on port " + Constants.PORT_NUMBER); } } catch (Exception e) { e.printStackTrace(); stop(); } } public static void main(String[] args) throws IOException { new GSBProxyServer(); } public static void stop() { logger.info("GSB TCP Proxy server stopping."); if (acceptor != null) { acceptor.unbind(); acceptor = null; } if (executor != null) { executor.shutdown(); executor = null; } } }

public class ProxyHandlerAdapter extends IoHandlerAdapter { private static Logger logger = Logger.getLogger(ProxyHandlerAdapter.class); private ClientHandlerAdapter clientHandlerAdapter; public ProxyHandlerAdapter(){ this.clientHandlerAdapter = new ClientHandlerAdapter(); } /** * When exception happens and it's caugth * * @param session * @param throwable */ public void exceptionCaught(IoSession session, Throwable throwable) throws Exception { throwable.printStackTrace(); session.close(false); } /** * Event for message received * * @param session * @param msg */ @SuppressWarnings("unchecked") public void messageReceived(IoSession session, Object msg) throws Exception { String str = msg.toString(); long initialTime = System.currentTimeMillis(); if(logger.isDebugEnabled()){ logger.debug("Entry messageReceived"); } try{ if(logger.isInfoEnabled()){ logger.info("messageReceived: " +str +" -from local:"+session.getLocalAddress()+" remote:"+session.getRemoteAddress()); } if (StringUtils.equalsIgnoreCase("quit", StringUtils.trim(str))) { session.close(true); if (clientHandlerAdapter != null) { clientHandlerAdapter.shutdown(); } return; } this.clientHandlerAdapter.broadcastMessage(str);//call clientHandler which is going to broadcast msg if(logger.isInfoEnabled()){ logger.info("send session acknowledge"); } session.write("ACK\r\n"); }catch (Exception ex) { logger.error(ex); ex.printStackTrace(); } if(logger.isDebugEnabled()){ logger.debug("Exit messageReceived: "+(System.currentTimeMillis()-initialTime)); } } }

public class ClientHandlerAdapter extends IoHandlerAdapter { private static Logger logger = Logger.getLogger(ClientHandlerAdapter.class); private int initPoolSize = Runtime.getRuntime().availableProcessors()+1; private int maxPoolSize = Constants.NUMBER_THREADS; private int keepAliveTimeInSecs = 5;//for each thread in our pool private int connectionTimeoutInMillis = 5 * 1000;//by default 5 seconds private SocketConnector socketConnector; private ExecutorService executor; public ClientHandlerAdapter(){ socketConnector = new NioSocketConnector(initPoolSize); executor = new OrderedThreadPoolExecutor(initPoolSize, maxPoolSize, keepAliveTimeInSecs, TimeUnit.SECONDS); socketConnector.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8")))); socketConnector.getFilterChain().addLast("threadPool", new ExecutorFilter(executor));//One thread pool for most events socketConnector.getFilterChain().addLast("threadPool-msgSent", new ExecutorFilter(initPoolSize, maxPoolSize, keepAliveTimeInSecs, TimeUnit.SECONDS, IoEventType.MESSAGE_SENT)); socketConnector.getFilterChain().addLast("threadPool-msgReceived", new ExecutorFilter(initPoolSize, maxPoolSize, keepAliveTimeInSecs, TimeUnit.SECONDS, IoEventType.MESSAGE_RECEIVED)); socketConnector.setHandler(this); socketConnector.getSessionConfig().setTcpNoDelay(true);//No delays on TCP communication socketConnector.getSessionConfig().setKeepAlive(false); socketConnector.setConnectTimeoutMillis(connectionTimeoutInMillis);//set timeout } /** * When exception happens and it's caugth * * @param session * @param throwable */ public void exceptionCaught(IoSession session, Throwable t) throws Exception { t.printStackTrace(); try{ CloseFuture closeFuture = session.close(true); //closeFuture.awaitUninterruptibly();// Wait until the connection is closed? closeFuture.setClosed();// Now connection should be closed. }catch (Exception ignore) { //ignore } } /** * Broadcast message * * @param message */ @SuppressWarnings("unchecked") public void broadcastMessage(final String message) throws Exception { long initialTime = System.currentTimeMillis(); if(logger.isDebugEnabled()){ logger.debug("Entry broadcastMessage"); } try{ String appName = StringUtils.substring(message, 3, 6); if(logger.isDebugEnabled()){ logger.debug("appName:" + appName); } List<Receiver> aTcpReceiverList = ReceiverFactory.applicationMap.get(appName); if(aTcpReceiverList!=null){ for(Receiver aTcpReceiver: aTcpReceiverList){ try{ this.sendMessage(aTcpReceiver, message); }catch (Exception ex) { logger.error("Error trying to connect to "+aTcpReceiver.getHostName()+":"+aTcpReceiver.getPortNumber()+". "+ex.getMessage()); try{ this.sendMessage(aTcpReceiver, message); }catch (Exception newEx) { logger.error("Error trying to connect <<again>> to "+aTcpReceiver.getHostName()+":"+aTcpReceiver.getPortNumber()+". "+newEx.getMessage()); ex.printStackTrace(); } } } } }catch (Exception ex) { logger.error(ex); ex.printStackTrace(); } if(logger.isDebugEnabled()){ logger.debug("Exit broadcastMessage: "+(System.currentTimeMillis()-initialTime)); } } /** * Sends a given message to a Receiver * * @param aTcpReceiver * @param message * @throws Exception * * @see com.vzw.gsb.network.Receiver */ @SuppressWarnings("unused") private void sendMessageOld(final Receiver aTcpReceiver, final String message) throws Exception{ long initialTime = System.currentTimeMillis(); if(logger.isDebugEnabled()){ logger.debug("Entry sendMessage"); } IoSession session = null; ConnectFuture connectFuture = socketConnector.connect(new InetSocketAddress(aTcpReceiver.getHostName(),aTcpReceiver.getPortNumber())); connectFuture.awaitUninterruptibly();//Wait until the connection attempt is finished. session = connectFuture.getSession(); session.write(message);//write message to remote server if(logger.isInfoEnabled()){ logger.info("message sent to: "+aTcpReceiver.getHostName()+":"+aTcpReceiver.getPortNumber()); } if(logger.isDebugEnabled()){ logger.debug("Exit sendMessage: "+(System.currentTimeMillis()-initialTime)); } //connectFuture.cancel();//Cancels the connection attempt and notifies all threads waiting for this future? } /** * Sends a given message to a Receiver. * I used a IoFutureListener on my ConnectFuture to wait for acknowledgment that the client has connected to the server. * Once we know we are connected, we can start writing data to the server * * @param aTcpReceiver * @param message * @throws Exception * * @see com.vzw.gsb.network.Receiver * @see org.apache.mina.core.future.IoFutureListener * @see org.apache.mina.core.future.ConnectFuture */ private void sendMessage(final Receiver aTcpReceiver, final String message) throws Exception{ long initialTime = System.currentTimeMillis(); if(logger.isDebugEnabled()){ logger.debug("Entry sendMessage"); } ConnectFuture connectFuture = socketConnector.connect(new InetSocketAddress(aTcpReceiver.getHostName(),aTcpReceiver.getPortNumber())); connectFuture.addListener(new IoFutureListener<IoFuture>(){ public void operationComplete(IoFuture future) { /*long initialTime = System.currentTimeMillis(); if(logger.isInfoEnabled()){ logger.info("Entry operationComplete"); }*/ ConnectFuture connFuture = (ConnectFuture)future; if(connFuture.isConnected()){ IoSession session = future.getSession(); session.write(message);//write message to remote server if(logger.isInfoEnabled()){ logger.info("message sent to: "+aTcpReceiver.getHostName()+":"+aTcpReceiver.getPortNumber()); } }else{ logger.error("Timeout trying to connecto to: "+aTcpReceiver.getHostName()+":"+aTcpReceiver.getPortNumber()); } /*if(logger.isInfoEnabled()){ logger.info("Exit operationComplete: "+(System.currentTimeMillis()-initialTime)); }*/ } }); if(logger.isDebugEnabled()){ logger.debug("Exit sendMessage: "+(System.currentTimeMillis()-initialTime)); } } /** * Event when message is received (ACK) from target server * * @param session * @param message */ @Override public void messageReceived(IoSession session, Object message) throws Exception { long initialTime = System.currentTimeMillis(); if(logger.isInfoEnabled() && StringUtils.isNotEmpty(message.toString())){//ACK coming from remote server logger.info("messageReceived: " +message);//+" -from local:"+session.getLocalAddress()+" remote:"+session.getRemoteAddress()+", closing session & closeFuture"); } if(logger.isDebugEnabled() && StringUtils.isNotEmpty(message.toString())){ logger.debug("Entry messageReceived"); } try{//once ACK comes, I close this session CloseFuture closeFuture = session.close(true); //closeFuture.awaitUninterruptibly();// Wait until the connection is closed? closeFuture.setClosed();// Now connection should be closed. if(logger.isDebugEnabled() && StringUtils.isNotEmpty(message.toString())){ logger.debug("isFutureClosed?"+closeFuture.isClosed()+", isSessionClosing?"+session.isClosing()); } }catch (Exception ignore) { //ignore } if(logger.isDebugEnabled() && StringUtils.isNotEmpty(message.toString())){ logger.debug("Exit messageReceived: "+(System.currentTimeMillis()-initialTime)); } } /** * Release all resources (SocketConnector) and ExecutorService * * @throws Exception */ public void shutdown() throws Exception { if(socketConnector!=null){ socketConnector.dispose(); } if (executor != null) { executor.shutdown(); } } }

How can I test it??? Just by create a client using java.net.Socket or just by using Telnet to that particular port

I didn't include other classes because they're not important

Log4J tips

Add thread name to my log file; sometimes we want to know which thread is being executed, well, try this:
ConversionPattern=%d [%5p] [%t] %c{1}.%m%n

That's right just by adding "%t", you can see which thread is doing what.

Spring MVC - Binding VO to a Form

Problema:
I have a VO and I wanted to populate it on my JSP and on my controller just process the VO already populated.

Solution:
@Controller @RequestMapping(value = "/loggers/*") public class LoggersConfigurationController extends BaseCustomController { private static final Logger log = Logger .getLogger(LoggersConfigurationController.class); @SuppressWarnings("unchecked") @RequestMapping(value = "configureLoggers.do", method = RequestMethod.GET) public String showScreen(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) { if (!this.isLoggedIn(request)) { return "redirect:/authentication/notLoggedIn.do"; } log.debug("Show Screen when RequestMethod.GET"); //By doing this I'm preparing my diabolic plan!!! LoggerVO loggerVO = new LoggerVO(); modelMap.put("LoggerVO", loggerVO); return "configuration/loggersConfiguration"; } @SuppressWarnings("unchecked") @RequestMapping(value = "configureLoggers.do", method = RequestMethod.POST) public String updateLogger( HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, @ModelAttribute(value="LoggerVO") LoggerVO loggerVO) { if (!this.isLoggedIn(request)) { return "redirect:/authentication/notLoggedIn.do"; } log.debug("Update logger when RequestMethod.POST"); List<String> messages = new ArrayList<String>(); log.debug("@ModelAttribute="+loggerVO); LogUtils.getInstance().setLogger(loggerVO); messages.add(loggerVO.getName()+" updated successfully to "+loggerVO.getLevel()); modelMap.put("KEY_LIST_MESSAGES", messages); //return "configuration/loggersConfiguration"; return "index-tabbed"; } }
On my POST method I'll handle my VO already populated.
This entry will do 50% of the job @ModelAttribute(value="LoggerVO") LoggerVO loggerVO
On my JSP I'll map using spring's tag library <%@taglib prefix="spring" uri="http://www.springframework.org/tags" %> <%@taglib prefix="form" uri="http://www.springframework.org/tags/form" %> <%@taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %> <H2>Loggers Configuration</H2> <form:form id="loggersForm" name="loggersForm" modelAttribute="LoggerVO" commandName="LoggerVO" action="/${pageContext.servletContext.servletContextName}/loggers/configureLoggers.do" method="POST"> <table width="100%"> <tr> <td><label for="name">Logger Name</label></td> <td> <form:select path="name" items="${applicationScope.KEY_LIST_LOGGERS}" itemValue="name" itemLabel="name"/> </td> </tr> <tr> <td><label for="level">Level</label></td> <td> <form:select path="level" items="${applicationScope.KEY_LIST_LOG_LEVELS}"/> </td> </tr> </table> <p> <input type="submit" value="Update"> </p> <div style="visibility: hidden"> <form:select path="appenderVOs"/> </div> </form:form> <c:if test="${!empty requestScope.KEY_LIST_MESSAGES}"> <script>alert("${requestScope.KEY_LIST_MESSAGES}");</script> </c:if>
By doing this modelAttribute="LoggerVO" commandName="LoggerVO"
I'm matching what I have on my form and what I have on my Controller <form:form id="loggersForm" name="loggersForm" modelAttribute="LoggerVO" commandName="LoggerVO" action="/${pageContext.servletContext.servletContextName}/loggers/configureLoggers.do" method="POST">
I hope this will help you!
Salu2

Cross Domain issue - Ajax

Who say yes???
I was working in a GUI for controlling components in different servers from one server - stopping, starting, purging queues & consumers; finally beans
The firSt thing it came to my mind was: "let's do it with AJAX to avoid multiple calls and decrease the traffic!!!"
Which AJAX framework should I choose??? Let's learn jQuery, because that one has a bunch of cool features which will be really helpfull to develop my GUI (check this site: flowplayer.org they have a bunch of demos which are really easy to follow and all based on jQuery)
My first issue was learnign that Ajax call, but after a few hours I could do my first ajax call using jQuery (I have a servlet which returns XML or JSON)

Now what??? If I'm accessing the servlet in the same context - domain, everything works fine, but... If I try to access my servlet but in another server

Tons tuve que eccharle coco
My solution was to create a ProxyServlet which basically will take my request and pass it to the remote server & servlet using an HttpClient and in the same way, it will get the response coming from the remote servlet, in other words, my ProxyServlet (in the same domain - context) will be the only one talking to my Ajax call, eventhough ProxyServlet will be talking to the remote server & servlet. Then I did it again  

This is my code:
import java.io.IOException; import java.util.HashMap; import java.util.Map; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.httpclient.DefaultHttpMethodRetryHandler; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.params.HttpConnectionManagerParams; import org.apache.commons.httpclient.params.HttpMethodParams; import org.apache.commons.lang.StringUtils; import org.apache.log4j.Logger; /** * ProxyServlet * Makes http request to an external resource and returns the response gotten. * This servlet is my workaround for Cross Domain (same origin policy) issue. * * @author Juan Cruz * @since Aug 11 2010 */ public class ProxyServlet extends HttpServlet { private static final Logger log = Logger.getLogger(ProxyServlet.class); private HttpClient httpClient = new HttpClient(); @Override public void init() throws ServletException { super.init(); this.initializeHttpClient(); } @Override protected void doGet(HttpServletRequest requqest, HttpServletResponse response) throws ServletException, IOException { this.doPost(requqest, response); } @Override protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/xml"); response.setHeader("Cache-Control", "no-cache"); String server = StringUtils.trim(request.getParameter("server")); String targetServlet = StringUtils.trim(request.getParameter("targetServlet")); Map<String, String> parameters = new HashMap<String, String>(); for(Object paramName : request.getParameterMap().keySet()){//Get only String parameters if (paramName instanceof String && request.getParameter(paramName+"") instanceof String) { parameters.put(paramName+"", request.getParameter(paramName+"")); } } String result = this.sendRequest(server,targetServlet, parameters); if(result!=null){ response.getWriter().write(result); }else{ response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR); } } /** * Send request to desired target * * @param server * @param targetServlet * @param parameters * @return String */ private String sendRequest(final String server, final String targetServlet, final Map<String, String> parameters) { log.debug("sendRequest "+server+targetServlet+", "+parameters); String responseBody = null; // Create a method instance. PostMethod method = new PostMethod("http://"+server+targetServlet); // Provide custom retry handler is necessary method.getParams().setParameter(HttpMethodParams.RETRY_HANDLER, new DefaultHttpMethodRetryHandler(3, false)); //add parameters for(String paramName : parameters.keySet()){ method.addParameter(paramName, parameters.get(paramName)); } try { httpClient.executeMethod(method); int statusCode = method.getStatusCode(); log.debug("HTTP status code:" +statusCode); if(statusCode==HttpServletResponse.SC_OK){ responseBody = method.getResponseBodyAsString(); }else{ log.warn(server+targetServlet+" responded with statusCode="+statusCode); } } catch (HttpException ex) { log.error("Fatal protocol violation: " + ex.getMessage(),ex); } catch (IOException ex) { log.error("Fatal transport error: " + ex.getMessage(),ex); } finally { // Release the connection. method.releaseConnection(); } return responseBody; } /** * Initialize ConnectionManager for HttpClient */ private void initializeHttpClient(){ HttpConnectionManagerParams managerParams = new HttpConnectionManagerParams(); //maximum number of connections allowed. managerParams.setMaxTotalConnections(10); managerParams.setDefaultMaxConnectionsPerHost(10); //check to see if the server closed the connection managerParams.setStaleCheckingEnabled(true); //time (ms) to wait for data after a connection is established managerParams.setSoTimeout(3000); //time (ms) to wait for a connection managerParams.setConnectionTimeout(3000); MultiThreadedHttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager(); connectionManager.setParams(managerParams); httpClient.setHttpConnectionManager(connectionManager); } }
This is my main servlet (the one which returns XML or JSON using json-simple project) import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.Set; import java.util.TreeSet; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.lang.BooleanUtils; import org.apache.commons.lang.StringUtils; import org.apache.log4j.Logger; import org.json.simple.JSONValue; import com.vzw.common.gsbsocketapp.consumer.ActiveMQDLConsumer; import com.vzw.common.gsbsocketapp.consumer.MOMConsumer; import com.vzw.common.gsbsocketapp.util.AppContext; /** * UtilsServlet * * @author Juan Cruz * @since July 15 2010 */ public class UtilsServlet extends HttpServlet { private static final long serialVersionUID = -6124305504614666753L; private static final Logger log = Logger.getLogger(UtilsServlet.class); @Override protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { this.doPost(request, response); } @Override protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String operation = request.getParameter("operation"); String consumerName = StringUtils.trim(request.getParameter("consumerName")); String suffix = StringUtils.trim(request.getParameter("suffix")); Boolean isJsonEnabled = BooleanUtils.toBoolean(StringUtils.trim(request.getParameter("json"))); Boolean result = false; if(StringUtils.isNotEmpty(operation)){ response.setContentType("text/xml"); response.setHeader("Cache-Control", "no-cache"); if(StringUtils.equalsIgnoreCase(operation, "getBeans")){ StringBuffer sb = new StringBuffer(); List<String> listBeans = this.getBeans(suffix); for(String beanName : listBeans){ sb.append("<bean>"); sb.append(beanName); sb.append("</bean>"); } if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(listBeans)); }else{ response.getWriter().write("<beans>" + sb.toString() + "</beans>"); } } if(StringUtils.equalsIgnoreCase(operation, "startMOMConsumer")){ this.startMOMConsumer(consumerName); result = Boolean.TRUE; if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(result)); }else{ response.getWriter().write("<result>"+result+"</result>"); } } if(StringUtils.equalsIgnoreCase(operation, "stopMOMConsumer")){ this.stopMOMConsumer(consumerName); result = Boolean.TRUE; if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(result)); }else{ response.getWriter().write("<result>"+result+"</result>"); } } if(StringUtils.equalsIgnoreCase(operation, "isStartedMOMConsumer")){ result = this.isStartedMOMConsumer(consumerName); if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(result)); }else{ response.getWriter().write("<result>"+result+"</result>"); } } if(StringUtils.equalsIgnoreCase(operation, "startAllConsumers")){ this.startAllConsumers(suffix); result = Boolean.TRUE; if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(result)); }else{ response.getWriter().write("<result>"+result+"</result>"); } } if(StringUtils.equalsIgnoreCase(operation, "stopAllConsumers")){ this.stopAllConsumers(suffix); result = Boolean.TRUE; if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(result)); }else{ response.getWriter().write("<result>"+result+"</result>"); } } if(StringUtils.equalsIgnoreCase(operation, "purgeDLQConsumer")){ this.purgeConsumer(consumerName); result = Boolean.TRUE; if(isJsonEnabled){ response.getWriter().write(JSONValue.toJSONString(result)); }else{ response.getWriter().write("<result>"+result+"</result>"); } } }else{ //Nada que mostrar response.setStatus(HttpServletResponse.SC_NO_CONTENT); } } /** * Search beans on Spring ApplicationContext with given suffix * * @param suffix * @return List<String> */ private List<String> getBeans(final String suffix){ if(log.isDebugEnabled()){ log.debug("getBeans (with suffix)=" +suffix); } List<String> listBeans = new ArrayList<String>(); String[] beanDefinitionNames = AppContext.getAppContext().getBeanDefinitionNames(); Set<String> listBeansFiltered = new TreeSet<String>();//Sort them & avoid duplicates for(String beanName : beanDefinitionNames){//filter by suffix provided if(StringUtils.trim(beanName).endsWith(suffix)){ listBeansFiltered.add(beanName); } } for(String item : listBeansFiltered){ listBeans.add(item); } if(log.isDebugEnabled()){ log.debug("beans retrieved =" +listBeans.size()); } return listBeans; } /** * Start consumer given * * @param consumerBeanId */ @SuppressWarnings("unchecked") private void startMOMConsumer(final String consumerBeanId){ if(log.isDebugEnabled()){ log.debug("startMOMConsumer beanId=" +consumerBeanId); } List<MOMConsumer>momConsumers = (List<MOMConsumer>)AppContext.getAppContext().getBean(consumerBeanId); for (MOMConsumer momConsumer : momConsumers) { if(!momConsumer.isStarted()){//start if is not started momConsumer.execute(); } } if(log.isDebugEnabled()){ log.debug(consumerBeanId+" started"); } } /** * Call execute method on given consumer * * @param consumerBeanId */ private void purgeConsumer(String consumerBeanId) { if(log.isDebugEnabled()){ log.debug("purgeConsumer beanId=" +consumerBeanId); } ActiveMQDLConsumer activeMQDLConsumer = (ActiveMQDLConsumer)AppContext.getAppContext().getBean(consumerBeanId); activeMQDLConsumer.execute(); if(log.isDebugEnabled()){ log.debug(consumerBeanId+" purged"); } } /** * Stop consumer given * * @param consumerBeanId */ @SuppressWarnings("unchecked") private void stopMOMConsumer(final String consumerBeanId){ if(log.isDebugEnabled()){ log.debug("stopMOMConsumer beanId=" +consumerBeanId); } List<MOMConsumer> momConsumers = (List<MOMConsumer>)AppContext.getAppContext().getBean(consumerBeanId); for (MOMConsumer momConsumer : momConsumers) { momConsumer.stop(); } if(log.isDebugEnabled()){ log.debug(consumerBeanId+" stopped"); } } /** * Verify state of given consumer - bean * * @param consumerBeanId * @return boolean */ @SuppressWarnings("unchecked") private boolean isStartedMOMConsumer(final String consumerBeanId){ boolean started = false; List<MOMConsumer> momConsumers = (List<MOMConsumer>)AppContext.getAppContext().getBean(consumerBeanId); for (MOMConsumer momConsumer : momConsumers) { started = momConsumer.isStarted(); } if(log.isDebugEnabled()){ log.debug("isStarted beanId=" +consumerBeanId+"?"+started); } return started; } /** * Start all consumers with given suffix * * @param suffix */ @SuppressWarnings("unchecked") private void startAllConsumers(final String suffix){ if(log.isDebugEnabled()){ log.debug("startAllConsumer suffix=" +suffix); } List<String> listBeans = this.getBeans(suffix); for(String consumerBeanId: listBeans){ List<MOMConsumer> momConsumers = (List<MOMConsumer>)AppContext.getAppContext().getBean(consumerBeanId); for (MOMConsumer momConsumer : momConsumers) { momConsumer.execute(); } } if(log.isDebugEnabled()){ log.debug(listBeans.size()+" beans started"); } } /** * Stop all consumers with given suffix * * @param suffix */ @SuppressWarnings("unchecked") private void stopAllConsumers(final String suffix){ if(log.isDebugEnabled()){ log.debug("stopAllConsumers suffix=" +suffix); } List<String> listBeans = this.getBeans(suffix); for(String consumerBeanId: listBeans){ List<MOMConsumer> momConsumers = (List<MOMConsumer>)AppContext.getAppContext().getBean(consumerBeanId); for (MOMConsumer momConsumer : momConsumers) { momConsumer.stop(); } } if(log.isDebugEnabled()){ log.debug(listBeans.size()+" beans stopped"); } } }

And this now, these are portions of my jQuery code:
var jsArray = new Array(); function parseXmlResponse(xml) { $(xml).find("bean").each(function(index) { jsArray.push($(this).text()); }); } function executeAjaxCallWithXML(){ $.ajax({ type: 'POST', url: 'http://'+server+'/GSBSocketAppWeb/proxyServlet', data: "operation="+operation+"&suffix="+suffix+"&server="+server+"&targetServlet=/GSBSocketAppWeb/utilsServlet", dataType: "xml", success: parseXmlResponse, async: false, error: function(xmlHttpRequest, textStatus, errorThrown){ alert(textStatus+", code: "+xmlHttpRequest.status); jsArray = new Array(); } }); } function executePostCallWithJson(){ $.post('http://'+server+'/GSBSocketAppWeb/proxyServlet?operation='+operation+'&suffix='+suffix+'&json=true&server='+server+'&targetServlet=/GSBSocketAppWeb/utilsServlet',function(data, textStatus){ // this will give us an array of objects var arrayItems = JSON.parse(data); for(var x=0; x < arrayItems.length; x++) { jsArrayBrowsers.push(arrayItems[x]); } }, 'text'); } function executeAjaxCallwithJson(){ //We can use .ajax or .get / .post $.ajax({ type: 'POST', url: 'http://'+server+'/GSBSocketAppWeb/proxyServlet', data: "operation="+operation+"&consumerName="+consumerName+"&json=true&server="+server+"&targetServlet=/GSBSocketAppWeb/utilsServlet", dataType: "json", success: function(data, textStatus){ if(data){ alert(consumerName+' was purged successfully'); button.value = 'Purged'; } }, error: function(xmlHttpRequest, textStatus){ alert(textStatus+", code: "+xmlHttpRequest.status); jsArrayBrowsers = new Array(); } }); }

You can get the additional JavaScript libraries from: JSON2 and my version of jQuery Tools

Adding Spring Web MVC part 2

Now I'll show you a couple of examples how it looks like a Controller & a JSP using Spring MVC.

From my personal perspective Defining a controller gives you a lot of power, because you can define a method to handle RequestMethod.GET, just to show a Form, and another method to handle the RequestMethod.POST to handle the "submit", cool isn't it?

import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; /** * Consumers Configuration Controller * * @author Juan Cruz */ @Controller @RequestMapping(value="/configuration/*") public class ConsumersConfigurationController extends BaseCustomController{ @Autowired private SomeInterfaceService myInstanceService; public ConsumersConfigurationController() { //You can intialize something or just use } @RequestMapping(value = "showConsumersConfiguration.do") public String showConsumersConfiguration(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) { if(!this.isLoggedIn(request)){ return "redirect:/authentication/logout.do"; } log.debug("showConsumersConfiguration"); modelMap.put("KEY_LIST_EAST_SERVERS", listEastServers); modelMap.put("KEY_LIST_WEST_SERVERS", listWestServers); modelMap.put("KEY_LIST_NORTH_SERVERS", listNorthServers); return "configuration/consumersConfiguration";//show jsp }

By adding @Controller you already told Spring, "hey this dude is going to be a Controller".

@RequestMapping(value="/configuration/*") means: "If my URL is WebContext/configuration/ this Controller is going to handle the Request"

Then on each method I can define my path below /configuration/ @RequestMapping(value = "showConsumersConfiguration.do"), something like this WebContext/configuration/showConsumersConfiguration.do

I almost forgot @Autowired which is for inject implementation of that Bean

If you want to handle an object like a form (bind an object to a form), check this out

<%@taglib prefix="spring" uri="http://www.springframework.org/tags" %> <%@taglib prefix="form" uri="http://www.springframework.org/tags/form" %> <form:form id="loginForm" name="loginForm" modelAttribute="UserVO" action="doLogin.do" method="post"> <table width="100%"> <tr> <td><label for="userId">Login</label></td> <td><form:input path="userId" size="20" title="By default you will see your US-WIN."/></td> </tr> <tr> <td><label for="password">Password</label></td> <td><form:password path="password" size="20" title="Enter your US-WIN password."/></td> </tr> </table> <p> <input type="submit" value="Authenticate"> </p> <form:hidden path="email"/> <form:hidden path="firstName"/> <form:hidden path="lastName"/> </form:form>

Important, include these tag libraries!

By using this attribute modelAttribute="UserVO" of form:form tag, I'm binding this line of my controller: modelMap.put("UserVO", userVO); with my form

public class UserVO implements Serializable { private String userId; private String password; private String email; private String firstName; private String lastName; }

If you see carefully, each attribute of my VO, has a reference on my JSP, at least as hidden field, but all of them are there

@Controller @RequestMapping(value = "/authentication/*") public class LoginController extends BaseCustomController{ @RequestMapping(value = "doLogin.do") public String authenticateUser(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap, @ModelAttribute UserVO paramUserVO) { } @RequestMapping(value = "login.do") public String showLogin(HttpServletRequest request, HttpServletResponse response, ModelMap modelMap) { UserVO userVO = new UserVO(); modelMap.put("UserVO", userVO); return "authentication/login";//show jsp }

Now my form has been binded to my VO @ModelAttribute UserVO paramUserVO

Now you're ready to play around with this thing!!!

Always go to the official documentation to get more details!!!

Adding Spring Web MVC

I'll try to be brief.

Basically, you need to add a new Servlet on you web.xml, a configuration file (let's call it webApplicationContext.xml) and some Annotations.

This is my example:

My web.xml <servlet> <servlet-name>webApplicationContext</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value>/WEB-INF/conf/spring/webApplicationContext.xml</param-value> </init-param> <load-on-startup>1</load-on-startup> </servlet> <servlet-mapping> <servlet-name>webApplicationContext</servlet-name> <url-pattern>*.do</url-pattern> </servlet-mapping>

The framework will, on initialization of a DispatcherServlet, look for a file named [servlet-name]-servlet.xml (webApplicationContext-servlet.xml) in WEB-INF by default, but if you provide parameter "contextConfigLocation" you can define a location and name for your configuration file.

My webApplicationContext.xml <?xml version="1.0" encoding="UTF-8" ?> <beans xmlns = "http://www.springframework.org/schema/beans" xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" xmlns:context = "http://www.springframework.org/schema/context" xsi:schemaLocation = "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"> <!--================== Annotation config =====================--> <context:annotation-config/> <!--================== Location of Controllers =====================--> <context:component-scan base-package = "com.vzw.common.gsbsocketapp.web.controller"/> <!--================== InternalResourceViewResolver =====================--> <bean class = "org.springframework.web.servlet.view.InternalResourceViewResolver"> <property name = "viewClass" value = "org.springframework.web.servlet.view.JstlView"/> <property name = "prefix" value = "/jsp/"/> <property name = "suffix" value = ".jsp"/> </bean> </beans>

Which basically is divided in 3 sections:

• We're going to use configuration based onn annotations
• Location of my Controllers
• And where are located my JSP's

In my next entry I'll cover how it looks like a Controller & JSP.