基于networkcomms V3通信框架的c#服务器与java客户端进行通信探讨 – 风清气正
首先说一下networkcomms 通信框架是商业版的，本文也并不提供。
对java不太熟悉，刚刚安装了eclipse,通信只实现了把字符从java客户端传到c#服务器，服务器收到消息后，返回一个字符消息给java客户端，java客户端显示收到的消息。
服务器端基于networkcomms V3 C#通信框架.
服务器端代码：
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 MessageContract; namespace Server
{
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) =>
{
// C#语言UTF-8字节数组转换成字符串
string recvStr = Encoding.UTF8.GetString(array, 0, array.Length);
//记录一下 证明消息已经收到
string newStr = “收到的字符串是“ + recvStr;
LogInfo.LogMessage(newStr,
“日志.txt“);//返回消息给java客户端
string serverStr = “服务器发出的消息123“;
byte[] newByte = Encoding.UTF8.GetBytes(serverStr);
//发送字节数据
connection.SendUnmanagedBytes(newByte);
});
}
private void Form1_FormClosing_1(object sender, FormClosingEventArgs e)
{
NetworkComms.Shutdown();
Environment.Exit(Environment.ExitCode);
}
}
}
客户端界面：
客户端java代码（对java不是很熟悉，代码可能有不妥之处）：
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
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(“已建立连接!—“);
String strContent
=“java发送的消息“;byte[] bs = strContent.getBytes(“UTF-8“);
//2.得到socket读写流
OutputStream os=socket.getOutputStream();
//3.利用流按照一定的操作，对socket进行读写操作
os.write(bs);
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);
}
}
catch(Exception s){
System.out.print(s);
}
}
}
回顾一下流程
（1）：打开 C#程序，开始监听
(2):运行java客户端，发送一个消息给c#服务器
byte[] bs = strContent.getBytes(“UTF-8“);
//2.得到socket读写流
OutputStream os=socket.getOutputStream();
//3.利用流按照一定的操作，对socket进行读写操作
os.write(bs);
os.flush();
（3）：c#服务器收到消息后，进行解析
<1>:
string recvStr = Encoding.UTF8.GetString(array, 0, array.Length);
//记录一下 证明消息已经收到
string newStr = “收到的字符串是“ + recvStr;
LogInfo.LogMessage(newStr,
“日志.txt“);
<2>返回消息给java客户端：
string serverStr = “服务器发出的消息123“;
byte[] newByte = Encoding.UTF8.GetBytes(serverStr);
//发送字节数据
connection.SendUnmanagedBytes(newByte);
（4）：java客户端接收消息，并显示出来
byte[] rebyte = readStream(ips);
String resultStr
= new String(rebyte, 0, rebyte.length, “UTF-8“);System.out.println(“收到主机消息：“ + resultStr);
java程序好像接收完消息后，就退出了，这里不知道怎样处理。
程序只在我的电脑测试成功，win7系统，未在其他系统进行测试。
c#工程文件下载 （不含通信框架）
参考文章：
http://www.cnblogs.com/iyangyuan/archive/2012/12/23/2829712.html
http://cuisuqiang.iteye.com/blog/1434416
http://blog.csdn.net/mecho/article/details/7342654
http://www.cnblogs.com/iyangyuan/archive/2012/12/23/2829712.html#3140522
http://cuisuqiang.iteye.com/blog/1434416
http://blog.csdn.net/paincupid/article/details/10635323
本文链接：基于networkcomms V3通信框架的c#服务器与java客户端进行通信探讨，转载请注明。
