Cocos2d-JS/Ajax用Protobuf与NodeJS/Java通信

package tutorial; option java_package = "com.whg.protobuf";
option java_outer_classname = "StudentProtoBuf"; message StudentProto {
optional int64 id = 1;
optional int32 age = 2;
optional bool sex = 3;
optional string name = 4;
}


public class Student { private long id;
private int age;
private boolean sex;
private String name; public Student() { } public Student(StudentProto proto){
id = proto.getId();
age = proto.getAge();
sex = proto.getSex();
if(proto.hasName()){
name = proto.getName();
}
} public byte[] toByteArray(){
StudentProto.Builder builder = StudentProto.newBuilder();
builder.setId(id);
builder.setAge(age);
builder.setSex(sex);
if(name != null){
builder.setName(name);
}
return builder.build().toByteArray();
} public static Student parse(byte[] bytes){
StudentProto proto = null;
try {
proto = StudentProto.parseFrom(bytes);
} catch (InvalidProtocolBufferException ex) {
throw new IllegalArgumentException(ex);
}
return new Student(proto);
} //省略setter/getter方法}


public static void main(String[] args) {
Student student = new Student();
student.setId(300);
student.setAge(30); byte[] bytes = student.toByteArray();
Parser.printHex(bytes);
Parser.printInt(bytes);
Parser.printBinary(bytes); Student student2 = Student.parse(bytes);
System.out.println(student2.getId());
System.out.println(student2.getAge());
}


function createXMLHttpRequest(){
if(window.ActiveXObject){ //IE only
return new ActiveXObject("Microsoft.XMLHTTP");
}else if(window.XMLHttpRequest){ //others
return new XMLHttpRequest();
}
}


var xhr = cc.loader.getXMLHttpRequest(); // or use createXMLHttpRequest() in Ajax
xhr.open("POST", "http://localhost:3000/protobuf");xhr.setRequestHeader("Content-Type","application/x-protobuf");
xhr.setRequestHeader("Accept","application/x-protobuf");if (xhr.overrideMimeType){
//这个是必须的，否则返回的是字符串，导致protobuf解码错误
//具体见http://www.ruanyifeng.com/blog/2012/09/xmlhttprequest_level_2.html
xhr.overrideMimeType("text/plain; charset=x-user-defined");
}


<script src="../protobuf/long.js"></script>
<script src="../protobuf/bytebuffer.js"></script>
<script src="../protobuf/protobuf.js"></script>
<script>
if (typeof dcodeIO === "undefined" || !dcodeIO.ProtoBuf) {
throw(new Error("ProtoBuf.js is not present. Please see www/index.html for manual setup instructions."));
}
</script>


package TestProtobuf;option java_package = "com.why.game.protobuf";
option java_outer_classname = "TestProtobuf";message TestProto{
optional int32 id = 1;
optional string name = 2;
}


var ProtoBuf = dcodeIO.ProtoBuf,
TestProtobuf = ProtoBuf.loadProtoFile("../protobuf/TestProtobuf.proto").build("TestProtobuf"),
TestProto = TestProtobuf.TestProto;


xhr.onreadystatechange = function(){
if (xhr.readyState == 4 && xhr.status == 200) {
var data = xhr.responseText;
var protobufResp = TestProto.decode(str2bytes(data));
var jsonResp = JSON.stringify(protobufResp);
console.log(jsonResp);
}
};var testProto = new TestProto({
id:10014,
name:"testProtoName测试987"
});
xhr.send(testProto.toBuffer());


function str2bytes(str){
var bytes = [];
for (var i = 0, len = str.length; i < len; ++i) {
var c = str.charCodeAt(i);
var byte = c & 0xff;
bytes.push(byte);
}
return bytes;
}


<script type="text/javascript" src="static/js/lib/socket.io/socket.io.js"></script>


message Message {
required string text = 1;
}


var ProtoBuf = dcodeIO.ProtoBuf;
var Message = ProtoBuf.loadProtoFile("./example.proto").build("Message");// Connect to our SocketIO server: node server.js
var socket = io.connect("http://localhost:3000");socket.on("connect", function () {
log.value += "Connected\n";
});socket.on("disconnect", function () {
log.value += "Disconnected\n";
});socket.on("message", function (message) {
try{
var msg = Message.decode(message);
log.value += "Received: " + msg.text + "\n";
}catch(err){
log.value += "Error: " + err + "\n";
}
});function send() {
if (socket.connected) {
var msg = new Message(text.value);
socket.send(msg.toBuffer());
log.value += "Sent: " + msg.text + "\n";
} else {
log.value += "Not connected\n";
}
}

// Connect to our server: node server.js
var socket = new WebSocket("ws://localhost:8080/ws");
socket.binaryType = "arraybuffer"; // We are talking binarysocket.onopen = function() {
log.value += "Connected\n";
};socket.onclose = function() {
log.value += "Disconnected\n";
};socket.onmessage = function(evt) {
try {
var msg = Message.decode(evt.data);
log.value += "Received: "+msg.text+"\n";
} catch (err) {
log.value += "Error: "+err+"\n";
}
};function send() {
if (socket.readyState == WebSocket.OPEN) {
var msg = new Message(text.value);
socket.send(msg.toBuffer());
log.value += "Sent: "+msg.text+"\n";
} else {
log.value += "Not connected\n";
}
}


var ProtoBuf = require("protobufjs");var TestProtobuf = ProtoBuf.loadProtoFile(protobufDir+"TestProtobuf.proto").build("TestProtobuf"),
TestProto = TestProtobuf.TestProto;


var http = require("http");var server = http.createServer(function(request, response){
//处理request和返回response响应
});server.listen(3000);


var server = http.createServer(function(request, response){
var filePath = false;
if(request.url == "/"){
filePath = "index.html";
}else if(request.method === "POST"){
if(request.url.indexOf("protobuf") != -1){
//BufferHelper参考链接 http://www.infoq.com/cn/articles/nodejs-about-buffer/
var bufferHelper = new BufferHelper();
request.on("data", function (chunk) {
bufferHelper.concat(chunk);
});
request.on("end", function () {
var buffer = bufferHelper.toBuffer();
var testProtoData = TestProto.decode(buffer);
response.writeHead(200, {"Content-Type": "application/x-protobuf"});
response.end(testProtoData.toBuffer());
});
} return;
}else{
filePath = request.url;
} var absPath = webRoot+filePath;
serveStatic(response, cache, absPath);
});


<!-- springframework 4.0.7 RELEASE -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>4.1.7.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>4.1.7.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>4.1.7.RELEASE</version>
</dependency><!-- spring mvc -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>4.1.7.RELEASE</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.1</version>
</dependency><!-- protobuf -->
<dependency>
<groupId>com.google.code</groupId>
<artifactId>protobuf-java</artifactId>
<version>2.4.0a</version>
</dependency>
<dependency>
<groupId>com.googlecode.protobuf-java-format</groupId>
<artifactId>protobuf-java-format</artifactId>
<version>1.2</version>
</dependency>


<!-- 引入上下文配置文件 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener><servlet>
<servlet-name>spring-web</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:spring/mvc.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet><servlet-mapping>
<servlet-name>spring-web</servlet-name>
<url-pattern>*.why</url-pattern>
</servlet-mapping>


<!-- 配置只扫描web下面类文件，即controller和interceptors，只关注mvc的配置，整个应用的配置在applicationContext.xml -->
<context:component-scan base-package="com.why.game.web.*" /><mvc:interceptors>
<bean class="com.why.game.web.interceptor.ControllerInterceptor" />
</mvc:interceptors>
<mvc:annotation-driven>
<mvc:message-converters>
<bean class="org.springframework.http.converter.protobuf.ProtobufHttpMessageConverter"/>
</mvc:message-converters>
</mvc:annotation-driven>


@Controller
@RequestMapping("/")
public class TestController { @RequestMapping(value="/protobuf")
@ResponseBody
public ResponseEntity<TestProto> protobuf(RequestEntity<TestProto> requestProto){
TestProto testProto = requestProto.getBody();
String s = new String(testProto.toByteArray());
System.out.println(s);
System.out.println(testProto);
HttpServiceCaller.printProtoStr(s);
return ResponseEntity.ok(testProto);
}}


var ProtoBuf = require("protobufjs");
var socketio = require("socket.io");// Initialize from .proto file
var builder = ProtoBuf.loadProtoFile(path.join(__dirname, "www", "example.proto")),
Message = builder.build("Message");// SocketIO adapter
var io = socketio.listen(server);
io.set("log level", 1);
io.sockets.on("connection", function(socket){
console.log(socket.id+" connecting...");
socket.on("disconnect", function() {
console.log("WebSocket disconnected");
});
socket.on("message", function(data) {
try {
// Decode the Message
var msg = Message.decode(data);
console.log("Received: "+msg.text);
// Transform the text to upper case
msg.text = msg.text.toUpperCase();
// Re-encode it and send it back
socket.send(msg.toBuffer());
//socket.emit('message', msg.toBuffer());
console.log("Sent: "+msg.text);
} catch (err) {
console.log("Processing failed:", err);
}
});
});


// WebSocket adapter
var wss = new ws.Server({server: server});
wss.on("connection", function(socket) {
console.log("New WebSocket connection");
socket.on("close", function() {
console.log("WebSocket disconnected");
});
socket.on("message", function(data, flags) {
if (flags.binary) {
try {
// Decode the Message
var msg = Message.decode(data);
console.log("Received: "+msg.text);
// Transform the text to upper case
msg.text = msg.text.toUpperCase();
// Re-encode it and send it back
socket.send(msg.toBuffer());
console.log("Sent: "+msg.text);
} catch (err) {
console.log("Processing failed:", err);
}
} else {
console.log("Not binary data");
}
});
});


<dependency>
<groupId>com.corundumstudio.socketio</groupId>
<artifactId>netty-socketio</artifactId>
<version>1.7.11-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.7</version>
</dependency><!-- protobuf -->
<dependency>
<groupId>com.google.code</groupId>
<artifactId>protobuf-java</artifactId>
<version>2.4.0a</version>
</dependency>
<dependency>
<groupId>com.googlecode.protobuf-java-format</groupId>
<artifactId>protobuf-java-format</artifactId>
<version>1.2</version>
</dependency>


public class SocketIOProtoServer implements ConnectListener, DisconnectListener{ private static final String HOST = "localhost";
private static final int PORT = 3001; private final SocketIOServer server; public SocketIOProtoServer(){
server = new SocketIOServer(config());
} private Configuration config(){
Configuration config = new Configuration();
config.setHostname(HOST);
config.setPort(PORT);
config.setMaxFramePayloadLength(1024 * 1024);
config.setMaxHttpContentLength(1024 * 1024);
return config;
} public void start(){
server.addConnectListener(this);
server.addDisconnectListener(this);
server.addEventListener("message", byte[].class, new DataListener<byte[]>() {
@Override
public void onData(SocketIOClient client, byte[] data, AckRequest ackRequest) {
Message message = Message.parse(data);
System.out.println("Received: "+message.getText());
// Transform the text to upper case
message.setText(message.getText().toUpperCase());
// Re-encode it and send it back
client.sendEvent("message", message.toByteArray());
System.out.println("Sent: "+message.getText());
}
}); server.start();
System.out.println("\n------ "+this.getClass().getSimpleName()+"start on "+PORT+" ------\n");
} public void stop(){
server.stop();
} @Override
public void onConnect(SocketIOClient client) {
System.out.println(client.getSessionId()+" connecting...");
} @Override
public void onDisconnect(SocketIOClient client) {
System.out.println(client.getSessionId()+" disconnecting...");
} public static void main(String[] args){
new SocketIOProtoServer().start();
}}


public class SocketIOProtoServer{ private static final String HOST = "localhost";
private static final int PORT = 3001; private final SocketIOServer server; public SocketIOProtoServer(){
server = new SocketIOServer(config());
} private Configuration config(){
Configuration config = new Configuration();
config.setHostname(HOST);
config.setPort(PORT);
config.setMaxFramePayloadLength(1024 * 1024);
config.setMaxHttpContentLength(1024 * 1024);
return config;
} public void start(){
server.addListeners(this); server.start();
System.out.println("\n------ "+this.getClass().getSimpleName()+"start on "+PORT+" ------\n");
} public void stop(){
server.stop();
} @OnConnect
public void onConnect(SocketIOClient client) {
System.out.println(client.getSessionId()+" connecting...");
} @OnDisconnect
public void onDisconnect(SocketIOClient client) {
System.out.println(client.getSessionId()+" disconnecting...");
} @OnEvent("message")
public void onData(SocketIOClient client, byte[] data, AckRequest ackRequest) {
Message message = Message.parse(data);
System.out.println("Received: "+message.getText());
// Transform the text to upper case
message.setText(message.getText().toUpperCase());
// Re-encode it and send it back
client.sendEvent("message", message.toByteArray());
System.out.println("Sent: "+message.getText());
} public static void main(String[] args){
new SocketIOProtoServer().start();
}}


public class Message { private String text; public Message() { } public Message(Example.Message proto){
text = proto.getText();
} public byte[] toByteArray(){
Example.Message.Builder builder = Example.Message.newBuilder();
builder.setText(text);
return builder.build().toByteArray();
} public static Message parse(byte[] bytes){
Example.Message proto = null;
try {
proto = Example.Message.parseFrom(bytes);
} catch (InvalidProtocolBufferException ex) {
throw new IllegalArgumentException(ex);
}
return new Message(proto);
} public String getText() {
return text;
} public void setText(String text) {
this.text = text;
}}


public final class WebSocketServer { static final boolean SSL = System.getProperty("ssl") != null;
static final int PORT = Integer.parseInt(System.getProperty("port", SSL? "8443" : "3000")); public static void main(String[] args) throws Exception {
// Configure SSL.
final SslContext sslCtx;
if (SSL) {
SelfSignedCertificate ssc = new SelfSignedCertificate();
sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
} else {
sslCtx = null;
} EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.handler(new LoggingHandler(LogLevel.INFO))
.childHandler(new WebSocketServerInitializer(sslCtx)); Channel ch = b.bind(PORT).sync().channel(); System.out.println("Open your web browser and navigate to " +
(SSL? "https" : "http") + "://127.0.0.1:" + PORT + '/'); ch.closeFuture().sync();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}


public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> { private static final String WEBSOCKET_PATH = "/ws"; private final SslContext sslCtx; public WebSocketServerInitializer(SslContext sslCtx) {
this.sslCtx = sslCtx;
} @Override
public void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
if (sslCtx != null) {
pipeline.addLast(sslCtx.newHandler(ch.alloc()));
}
pipeline.addLast(new HttpServerCodec());
pipeline.addLast(new HttpObjectAggregator(65536));
pipeline.addLast(new WebSocketServerProtocolHandler(WEBSOCKET_PATH, null, true));
pipeline.addLast(new WebSocketFrameHandler());
}
}


public class WebSocketFrameHandler extends SimpleChannelInboundHandler<WebSocketFrame> { private static final Logger logger = LoggerFactory.getLogger(WebSocketFrameHandler.class); @Override
protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {
// ping and pong frames already handled if (frame instanceof TextWebSocketFrame) {
// Send the uppercase string back.
String request = ((TextWebSocketFrame) frame).text();
logger.info("{} received {}", ctx.channel(), request);
ctx.channel().writeAndFlush(new TextWebSocketFrame(request.toUpperCase(Locale.US)));
} else if(frame instanceof BinaryWebSocketFrame){
ByteBuf byteBuf = ((BinaryWebSocketFrame) frame).content();
byte[] data = new byte[byteBuf.capacity()];
byteBuf.readBytes(data);
Message message = Message.parse(data);
System.out.println("Received: "+message.getText());
// Transform the text to upper case
message.setText(message.getText().toUpperCase());
// Re-encode it and send it back
byte[] bytes = message.toByteArray();
ByteBuf payload = ctx.alloc().buffer(bytes.length);
payload.writeBytes(bytes);
ctx.channel().writeAndFlush(new BinaryWebSocketFrame(payload));
System.out.println("Sent: "+message.getText());
} else {
String message = "unsupported frame type: " + frame.getClass().getName();
throw new UnsupportedOperationException(message);
}
}
}