版权所有:
weaving-socket,已.net core 为基础,设计基于TCP通信的交互框架。是编写物联网,消息队列,websocket应用,移动通信应用,IM等完美的选择。 可规范先后台交互处理,可支持,B/C,C/S,手机移动标准化的通信方式。
与其他架构区别,除了同意数据接收外,架构自带内置协议,保证数据完整
P2Pclient socket客户端端类库
WeaveUDPclient UDP客户端端类库
客户类库中事件包括 ReceiveServerEventbit - Bytes, custom 类型接收事件 ReceiveServerEvent Json 类型接收事件 Timeoutevent 客户端断链事件
Send()客户端发送数据方法
创建一个控制台程序,引用类库 using Weave.Base; using Weave.Server;
然后编写代码
static void Main(string[] args)
{
WeaveP2Server server = new WeaveP2Server(WeaveDataTypeEnum.Bytes);//初始化类库
server.receiveevent += Server_receiveevent;//注册接收事件
//当然还有很多其他的事件可以注册,比如新增连接事件,连接断开事件
server.start(8989);//启动监听8989端口
Console.WriteLine("8989listen:");
Console.ReadKey();
}
private static void Server_receiveevent(byte command, string data, System.Net.Sockets.Socket soc)
{
Console.WriteLine(data);//输出客户端发来的信息
}
然后创建一个控制台程序,引用类库 using Weave.TCPClient; using Weave.Base;
然后编写代码
P2Pclient client = new P2Pclient(DataType.bytes);//初始化类库
static void Main(string[] args)
{
client.timeoutevent += Client_timeoutevent;//注册连接超时事件
client.receiveServerEvent += Client_receiveServerEvent;//注册接收事件
client.start("127.0.0.1", 8989, false);//启动连接127.0.0.1服务器的8989端口。不需要服务器TOKEN
System.Threading.Thread.Sleep(1000);
Console.WriteLine("server link OK:");
client.send(0x1, "test2017-5-5");//给服务器发送信息,参数1,0x01指令,指令可以设置0-254,其中0x9c与0xff,是保留指令不能使用。参数2:发送string类型的数据。
Console.WriteLine("send:test2017-5-5");
Console.ReadKey();
}
private static void Client_receiveServerEvent(byte command, string text)
{
//command是从服务器发来的指令
//text是从服务器发来的数据
}
private static void Client_timeoutevent()
{
//连接超时或断线会启动此事件
client。Restart(false);//重新连接
}
Weave.Client.TcpSynClient tcpSynClient = new TcpSynClient(Weave.Client.DataType.bytes, "127.0.0.1", 9903);
tcpSynClient.Start();
tcpSynClient.Send(0x01, "asdasd");//发送请求
while(true)
var commdata = tcpSynClient.Receives(null);//等待回执
socket = new UDCsocket({
//115.28.26.204
ip: 'ws://127.0.0.1', port: 11001, conn: function () {
// socket.settakon("123123");
alert("连接成功");
//socket.SendData(1, "login", "123123ssdfsdf", "");
}
, recData: function (text) {
//$('#test').html("");
$('#test').append("收到:" + text + '<br/> ')//这个意思你们都懂了把
}
, close: function () { alert("连接关闭"); }
, error: function (msg) { alert("连接错误" + msg); }
, jump: function (ip) { alert("服务器超过最大连接,请连接其他服务器:" + ip); }
});
socket.SendData(0x02, "GetLISTimei", '', ""); //发送内容
WeaveMicro 微服务架构 支持.net core 2.x-5.x,正常使用
Weave微服务架构 主要目的,尽量简化和减少开发复杂度和难度,尽量双击可使用。 尽量不集成操作数据库等内容,由开发习惯自己选择。只负责最核心内容。 尽量简化调用方法和启动的方式方法
WeavingDB是一个轻量级的便捷的内存数据库,缓存库。 基于 weaving-socket ,欢迎大家学习使用
https://gitee.com/UDCS/WeavingDB
基于 weaving-socket 通讯架构制作的内存数据库,缓存库。
WsocketAutoUpPrj是一个几个weaving-socket的软件版本自动升级更新程序示例。
由于版本变化,一些视频内容与版本不服,仅供参考
QQ交流群17375149 联系QQ/微信:20573886
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。
1. Open source ecosystem
2. Collaboration, People, Software
3. Evaluation model