微服务框架 Spark Framework

摘要：我是广告本人的直播课程在月份就要开始了，希望小伙伴们支持一下，现在报名有优惠噢

源码：http://git.oschina.net/sancha...

Spark Framework beetl fastjson 结合

项目结构如下

pom.xml如下：

    4.0.0

    com.coderknock
    TestSpark
    1.0-SNAPSHOT
    
        1.2.17
        1.7.21
    
    
        
            com.ibeetl
            beetl
            2.4.0
        
        
            com.sparkjava
            spark-core
            2.5
        
        
            redis.clients
            jedis
            2.8.1
        
        
            com.alibaba
            fastjson
            1.2.12
        
        
            org.slf4j
            slf4j-log4j12
            ${slf4j_version}
        
        
            org.jodd
            jodd-http
            3.7.1
        
    

    

        
            
                
                    org.apache.maven.plugins
                    maven-compiler-plugin
                    2.5.1
                    
                        1.8
                        1.8
                    
                
            
        

        
            
                org.apache.maven.plugins
                maven-compiler-plugin
                
                    1.8
                    1.8
                    UTF-8
                
            
            
                org.apache.maven.plugins
                maven-war-plugin
                2.1.1
                
                    test
                
            
            
                org.apache.maven.plugins
                maven-dependency-plugin
                
                    
                        install
                        install
                        
                            sources
                        
                    
                
            

        
    

WebSocket推送，普通Get请求以及返回Json的请求、使用Beetl进行视图解析的方法：

/**
 * 拿客 www.coderknock.com
 * 微信公众号 coderknock
 * 作者：三产
 */

import com.alibaba.fastjson.JSON;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashMap;

import static spark.Spark.*;

public class Test {
    private static Logger logger = LoggerFactory.getLogger(Test.class);

    public static void main(String[] args) {
        //设置端口
        port(9090);
        //EchoWebSocket不能是内部类
        webSocket("/echo", EchoWebSocket.class);
        //这个必须有，不然注册不成功
        init();
        // matches "GET /hello/foo" and "GET /hello/bar"
        // request.params(":name") is "foo" or "bar"
        get("/hello/:name", (request, response) -> {
            //使用Beetl进行视图的解析
            return Tmpl.render("hello.html", request.params());
        });
        // matches "GET /say/hello/to/world"
        // request.splat()[0] is "hello" and request.splat()[1] "world"
        get("/say/*/to/*", (request, response) -> {
            response.type("application/json");
            HashMap map = new HashMap();
            map.put("1", request.splat()[0]);
            map.put("2", request.splat()[1]);
            //打印结果
            logger.debug("$$$$$$$$$$$$$$$$$" + JSON.toJSON(map).toString());
            return JSON.toJSON(map);
        });
        get("/home", (request, response) -> {
            return Tmpl.render("index.html");
        });
        int i = 0;        
        //WebSocket主动推送的实现，启动轮询，定时发送消息
        while (true) {
            try {
                Thread.currentThread().sleep(1000);
                i++;
                logger.debug("--->" + i);
                if (i % 5 == 1) {
                    EchoWebSocket.send(i);
                    logger.debug("--->第" + i + "次发送");
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

WebSocket实现类

import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * 拿客 www.coderknock.com
 * 微信公众号 coderknock
 * 作者：三产
 */
@WebSocket
public class EchoWebSocket {
    private static Logger logger = LoggerFactory.getLogger(EchoWebSocket.class);
    // Store sessions if you want to, for example, broadcast a message to all users
    private static final Queue sessions = new ConcurrentLinkedQueue<>();

    @OnWebSocketConnect
    public void connected(Session session) {
        sessions.add(session);
        //建立连接的时候
        logger.debug("新增了Session" + session.toString());
    }

    @OnWebSocketClose
    public void closed(Session session, int statusCode, String reason) {
        sessions.remove(session);
        //关闭连接或者浏览器关闭时
        logger.debug("删除了Session" + session.toString());
    }

    @OnWebSocketMessage
    public void message(Session session, String message) throws IOException {
        //获取到客户端发送的消息时，对消息进行输出，病简单处理返回另一个消息
        System.out.println("Got: " + message);   // Print message
        session.getRemote().sendString(message + "1231"); // and send it back
    }

    public static void send(int i) {
        //这里只是简单的给所有用户推送，其实可以改造一下（将Session与用户id之类的通过发送消息的方式一一对应，这样可以为特定用户进行消息的发送）
        sessions.forEach(session -> {
                    try {                        
                        session.getRemote().sendString("第" + i + "次主动推送");
                    } catch (Exception e) {
                        logger.error("主动推送失败", e);
                    }
                }
        );
    }
}

Beetl的一个简单封装：

import org.beetl.core.Configuration;
import org.beetl.core.GroupTemplate;
import org.beetl.core.Template;
import org.beetl.core.resource.WebAppResourceLoader;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashMap;
import java.util.Map;

/**
 * 拿客 www.coderknock.com
 * 微信公众号 coderknock
 * 作者：三产
 */
public class Tmpl {
    private static GroupTemplate gt;
    private static Logger logger = LoggerFactory.getLogger(Tmpl.class);

    static {
        try {
            Configuration cfg = Configuration.defaultConfiguration();
            WebAppResourceLoader resourceLoader = new WebAppResourceLoader();
            gt = new GroupTemplate(resourceLoader, cfg);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static String render(String tmplPath) {
        Template t = gt.getTemplate(tmplPath);
        return t.render();
    }

    public static String render(String tmplPath, Map param) {
        Template t = gt.getTemplate(tmplPath);
        Map convertMap = new HashMap<>();
        try {
            param.forEach((x, y) -> {
                if (x.startsWith(":")) {
                    convertMap.put(x.substring(1), y);
                }
            });
        } catch (Exception e) {
            logger.error("转换失败", e);
        }
        t.binding(convertMap);
        return t.render();
    }
}

Get请求高并发测试：

/**
 * 拿客 www.coderknock.com
 * 微信公众号 coderknock
 * 作者：三产
 */

import jodd.http.HttpRequest;
import jodd.http.HttpResponse;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class TestGet {
    //大家可以适当加大，但是如果太大可能会导致get请求发送失败，大家有优化建议可以告诉我（客户端问题，并不是Spark处理不了高并发）
    private static int thread_num = 500;
    private static int client_num = 500;

    public static void main(String[] args) {
        long time = System.currentTimeMillis();
        ExecutorService exec = Executors.newCachedThreadPool();
        final Semaphore semp = new Semaphore(thread_num);
        for (int index = 0; index < client_num; index++) {
            final int NO = index;
            Runnable run = new Runnable() {
                public void run() {
                    try {
                        semp.acquire();
                        System.out.println("------------------|" + NO + "|------------------");
                        HttpResponse response = HttpRequest
                                .get("http://localhost:9090/say/Hello-" + NO + "/to/World" + NO
                                )
                                .acceptEncoding("gzip")
                                .send();

                        System.out.println(response.unzip());
                        System.out.println("------------------&" + NO + "&------------------");
                        //业务逻辑
                        semp.release();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            };
            exec.execute(run);
        }
        exec.shutdown();
    }
}


WebSocket可以通过websocket.html测试（建议使用IE8以上浏览器）：
![WebSocket测试](http://img.coderknock.com/201606/03214119104_02161833_kTuD.png "WebSocket测试")
先点击“建立连接”，然后可以填写一些内容，点击“发送数据”，连接建立后就开始了主动推送，我设置的是5秒钟一次。

本人的直播课程在 7 月份就要开始了，希望小伙伴们支持一下，现在报名有优惠噢

https://segmentfault.com/l/15...

https://segmentfault.com/l/15...