基于networkcomms V3通信框架的c#服务器与java客户端进行通信之Protobuf探讨

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using NetworkCommsDotNet;
using NetworkCommsDotNet.DPSBase;
using NetworkCommsDotNet.Tools;

using NetworkCommsDotNet.Connections;
using NetworkCommsDotNet.Connections.TCP;
using System.Net;
using Google.ProtocolBuffers;
using tutorial;

namespace protobufServer
{
    public partial class Form1 : Form
    {
        SendReceiveOptions sro = new SendReceiveOptions(DPSManager.GetDataSerializer<NullSerializer>(), null, null);
      
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            //服务器开始监听客户端的请求
            //开始监听某端口
           //与其他语言通信   禁用ApplicationLayerProtocolStatus
            TCPConnectionListener  listener=new TCPConnectionListener (sro,ApplicationLayerProtocolStatus.Disabled);

            Connection.StartListening(listener, new IPEndPoint(IPAddress.Parse(txtIP.Text), int.Parse(txtPort.Text)));
          
            button1.Text = "监听中";
            button1.Enabled = false;

            //此方法中包含服务器具体的处理方法。
            StartListening();
        }

        private void StartListening()
        { 
            NetworkComms.DisableLogging();
             
            //array  收到字节
            NetworkComms.AppendGlobalIncomingUnmanagedPacketHandler((header, connection, array) =>
            {
                Person person2 = Person.ParseFrom(array);
              
                LogInfo.LogMessage(person2.Id + "," + person2.Name + "， " + person2.Email, "日志.txt");
                IList<Person.Types.PhoneNumber> lstPhones = person2.PhoneList;
                foreach (Person.Types.PhoneNumber phoneNumber in lstPhones)
                {
                  
                    LogInfo.LogMessage(phoneNumber.Number.ToString(), "日志.txt");
                }
                 
                //返回一个数据给客户端
                //序列化
                Person.Builder builder = new Person.Builder();
                builder.SetEmail("名山大川@email.com");
                builder.SetId(1);
                builder.SetName("大江东去浪淘尽");
                builder.AddPhone(new Person.Types.PhoneNumber.Builder().SetNumber("12345679").SetType(Person.Types.PhoneType.MOBILE));
                builder.AddPhone(new Person.Types.PhoneNumber.Builder().SetNumber("123456").SetType(Person.Types.PhoneType.HOME));
                Person person = builder.Build();
                byte[] buf = person.ToByteArray();
                connection.SendUnmanagedBytes(buf); 

            });
             
        }
     
        private void Form1_FormClosing_1(object sender, FormClosingEventArgs e)
        {
            NetworkComms.Shutdown();
            Environment.Exit(Environment.ExitCode);
        }
    }
}

package com.protobuftest.protobuf;

import java.io.BufferedReader;  
import java.io.InputStream;  
import java.io.InputStreamReader;  
import java.io.OutputStream;  
import java.io.PrintWriter;  
import java.net.Socket;  
import com.google.protobuf.InvalidProtocolBufferException;
import java.util.List;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.lang.Runtime;
import java.io.IOException;
 


public class First extends Thread{
    
    public static byte[] readStream(InputStream inStream) throws Exception {  
        int count = 0;  
        while (count == 0) {  
            count = inStream.available();  
        }  
        byte[] b = new byte[count];  
        inStream.read(b);  
        return b;  
    }  

    /**
     * @param args
     */
    public static void main(String[] args) throws Exception {
        Socket socket = null;
     
        int j = 0;
        try {
         
            socket = new Socket("127.0.0.1", 3000);
            if (socket.isConnected()) {
                System.out.println("已建立连接!---");
                
                   PersonProbuf.Person.Builder builder = PersonProbuf.Person.newBuilder();
                   builder.setEmail("kkk＠email.com");
                   builder.setId(1);
                   builder.setName("TestName");
                   builder.addPhone(PersonProbuf.Person.PhoneNumber.newBuilder().setNumber("131111111").setType(PersonProbuf.Person.PhoneType.MOBILE));
                   builder.addPhone(PersonProbuf.Person.PhoneNumber.newBuilder().setNumber("011111").setType(PersonProbuf.Person.PhoneType.HOME)); 
                   PersonProbuf.Person person = builder.build();
                   byte[] buf = person.toByteArray();
                
                //2.得到socket读写流  
                OutputStream os=socket.getOutputStream();  
                 
                //3.利用流按照一定的操作，对socket进行读写操作  
            
                os.write(buf);
                os.flush();
               
                   
                    
                System.out.println("----------------------------------");  
                     
                InputStream ips = socket.getInputStream();  
                byte[] rebyte = readStream(ips);  
                     
              //  String resultStr = new String(rebyte, 0, rebyte.length, "UTF-8"); 
              // System.out.println("收到主机消息：" + resultStr);  
                
                
                PersonProbuf.Person person2 = PersonProbuf.Person.parseFrom(rebyte);
                System.out.println(person2.getId()+","+person2.getName() + "， " + person2.getEmail());
                List<PersonProbuf.Person.PhoneNumber> lstPhones = person2.getPhoneList();
                for(PersonProbuf.Person.PhoneNumber phoneNumber : lstPhones) {
                System.out.println(phoneNumber.getNumber());
                
                }
                        
                      
            }
             
        }
           
        catch(Exception s){
            System.out.print(s);
        }
        
    }
    
    
}