android wcf双工通讯,利用WCF双工模式实现即时通讯

2023-10-10 09:10

本文主要是介绍android wcf双工通讯,利用WCF双工模式实现即时通讯,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

概述

WCF陆陆续续也用过多次,但每次都是浅尝辄止,以将够解决问题为王道,这几天稍闲,特寻了些资料看,昨晚尝试使用WCF的双工模式实现了一个简单的即时通讯程序,通过服务端转发实现客户端之间的通讯。这只是个Demo,没有考虑异常处理和性能问题。解决方案结构如下:

a687b3fc1faff1d216788944f2e23ae3.png

契约

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

namespace Service.Interface

{

[ServiceContract(CallbackContract = typeof(ICallBack))]

public interface INoticeOperator

{

[OperationContract]

void Register(String id);

[OperationContract]

void UnRegister(String id);

[OperationContract]

void SendMessage(String from, String to, String message);

}

}

该接口定义了三个行为,分别是:

•注册

•注销

•发消息

其中,在特性[ServiceContract(CallbackContract = typeof(ICallBack))]中指定了用于服务端回调客户方法的契约ICallBack,其定义如下:

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

namespace Service.Interface

{

public interface ICallBack

{

[OperationContract(IsOneWay = true)]

void Notice(String message);

}

}

实体

本Demo只有一个实体,用来表示已经注册用户的Id和对应的回调契约的具体实现的实例:

using Service.Interface;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

namespace Models

{

public class Client

{

public String Id { get; set; }

public ICallBack CallBack { get; set; }

}

}

契约的实现代码

using Models;

using Service.Interface;

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

namespace Service

{

public class NoticeOperator : INoticeOperator

{

private static List clientList = new List();

public void Register(string id)

{

Console.WriteLine("register:" + id);

ICallBack callBack = OperationContext.Current.GetCallbackChannel();

clientList.Add(new Client() { Id = id, CallBack = callBack });

}

public void UnRegister(string id)

{

Console.WriteLine("unRegister:" + id);

Client client = clientList.Find(c => c.Id == id);

if (client != null)

{

clientList.Remove(client);

}

}

public void SendMessage(string from, string to, string message)

{

Client client = clientList.Find(c => c.Id == to);

if (client != null)

{

String longMessage = String.Format("message from {0} to {1} at {2} : {3}", from, to, DateTime.Now.ToString("HH:mm:ss"), message);

Console.WriteLine(longMessage);

client.CallBack.Notice(longMessage);

}

}

}

}

Register方法用来把Client实体加入到一个列表中,模拟注册行为,Clinet实体包含了用户信息和实现了回调契约的一个实例对象。

UnRegister方法用来把一个Client从列表中移除,模拟注销行为。

SendMessage方法用来发送消息,第一个参数是发送者的Id,第二个参数是消息接受者的Id,第三个参数是发送内容,该方法先将消息在服务端打印出来,然后再回调消息接收者对应的回调契约的具体实现类的实例对象的Notice方法以达到服务端向客户端发送消息的目的。

宿主

using Service;

using Service.Interface;

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.ServiceModel.Description;

using System.Text;

using System.Threading.Tasks;

namespace Hosting

{

class Program

{

static void Main(string[] args)

{

using (ServiceHost host = new ServiceHost(typeof(NoticeOperator)))

{

host.AddServiceEndpoint(typeof(INoticeOperator), new NetTcpBinding(), "net.tcp://127.0.0.1:9527/NoticeOperator");

host.Opened += (s, e) => Console.WriteLine("service is running...");

host.Open();

Console.ReadLine();

}

}

}

}

宿主是一个控制台应用程序,使用的绑定类型为NetTcpBinding,端口是华安的华府的终生代号。

客户端代码

实现回调接口

using Service.Interface;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

namespace Test

{

class CallBack : ICallBack

{

public void Notice(string message)

{

Console.WriteLine(message);

}

}

}

模拟注册,发消息和注销

using Service.Interface;

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

namespace Test

{

class Program

{

static void Main(string[] args)

{

InstanceContext context = new InstanceContext(new CallBack());

using (ChannelFactory factory = new DuplexChannelFactory(context, new NetTcpBinding(), "net.tcp://127.0.0.1:9527/NoticeOperator"))

{

INoticeOperator proxy = factory.CreateChannel();

String selfId = args[0];

String friendId = args[1];

proxy.Register(selfId);

Console.WriteLine("----------Register------------");

while(true)

{

String message = Console.ReadLine();

if (message == "q")

{

proxy.UnRegister(selfId);

break;

}

else

{

proxy.SendMessage(selfId, friendId, message);

}

}

}

}

}

}

在CMD中运行test.exe Joey Ross表示Joey注册,要给他的朋友Ross发送消息;再起一个进程test.exe Ross Joey表示Ross注册,要给他的朋友Joey发送消息。进程启动后输入一些字符按回车即发送至了对方,输入q回车注销并退出程序。如下图所示:

Ross:

6d863d9a0ff3f3f09850986e4ac65731.png

Joey:

f3ec616fcf36e79cdb2287121a8adbf7.png

服务端:

9953b90cc123739f11bb28ebde32a9d9.png

参考资料

•无废话WCF入门教程五[WCF的通信模式]

•同事 @麦枫 的代码

•《WCF全面解析》

后记

这仅仅是个Demo,在实际项目中如果同时在线人数非常多,这样做的性能是否可行还需进一步对WCF双工模式的工作方式进行深入学习。

解决方案下载地址:WCFDemo

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

这篇关于android wcf双工通讯,利用WCF双工模式实现即时通讯的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/179482

相关文章

Spring Boot 实现 IP 限流的原理、实践与利弊解析

《SpringBoot实现IP限流的原理、实践与利弊解析》在SpringBoot中实现IP限流是一种简单而有效的方式来保障系统的稳定性和可用性,本文给大家介绍SpringBoot实现IP限... 目录一、引言二、IP 限流原理2.1 令牌桶算法2.2 漏桶算法三、使用场景3.1 防止恶意攻击3.2 控制资源

springboot下载接口限速功能实现

《springboot下载接口限速功能实现》通过Redis统计并发数动态调整每个用户带宽,核心逻辑为每秒读取并发送限定数据量,防止单用户占用过多资源,确保整体下载均衡且高效,本文给大家介绍spring... 目录 一、整体目标 二、涉及的主要类/方法✅ 三、核心流程图解(简化) 四、关键代码详解1️⃣ 设置

Nginx 配置跨域的实现及常见问题解决

《Nginx配置跨域的实现及常见问题解决》本文主要介绍了Nginx配置跨域的实现及常见问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来... 目录1. 跨域1.1 同源策略1.2 跨域资源共享(CORS)2. Nginx 配置跨域的场景2.1

Python中提取文件名扩展名的多种方法实现

《Python中提取文件名扩展名的多种方法实现》在Python编程中,经常会遇到需要从文件名中提取扩展名的场景,Python提供了多种方法来实现这一功能,不同方法适用于不同的场景和需求,包括os.pa... 目录技术背景实现步骤方法一:使用os.path.splitext方法二:使用pathlib模块方法三

CSS实现元素撑满剩余空间的五种方法

《CSS实现元素撑满剩余空间的五种方法》在日常开发中,我们经常需要让某个元素占据容器的剩余空间,本文将介绍5种不同的方法来实现这个需求,并分析各种方法的优缺点,感兴趣的朋友一起看看吧... css实现元素撑满剩余空间的5种方法 在日常开发中,我们经常需要让某个元素占据容器的剩余空间。这是一个常见的布局需求

HTML5 getUserMedia API网页录音实现指南示例小结

《HTML5getUserMediaAPI网页录音实现指南示例小结》本教程将指导你如何利用这一API,结合WebAudioAPI,实现网页录音功能,从获取音频流到处理和保存录音,整个过程将逐步... 目录1. html5 getUserMedia API简介1.1 API概念与历史1.2 功能与优势1.3

Java实现删除文件中的指定内容

《Java实现删除文件中的指定内容》在日常开发中,经常需要对文本文件进行批量处理,其中,删除文件中指定内容是最常见的需求之一,下面我们就来看看如何使用java实现删除文件中的指定内容吧... 目录1. 项目背景详细介绍2. 项目需求详细介绍2.1 功能需求2.2 非功能需求3. 相关技术详细介绍3.1 Ja

使用Python和OpenCV库实现实时颜色识别系统

《使用Python和OpenCV库实现实时颜色识别系统》:本文主要介绍使用Python和OpenCV库实现的实时颜色识别系统,这个系统能够通过摄像头捕捉视频流,并在视频中指定区域内识别主要颜色(红... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间详解

PostgreSQL中MVCC 机制的实现

《PostgreSQL中MVCC机制的实现》本文主要介绍了PostgreSQL中MVCC机制的实现,通过多版本数据存储、快照隔离和事务ID管理实现高并发读写,具有一定的参考价值,感兴趣的可以了解一下... 目录一 MVCC 基本原理python1.1 MVCC 核心概念1.2 与传统锁机制对比二 Postg

SpringBoot整合Flowable实现工作流的详细流程

《SpringBoot整合Flowable实现工作流的详细流程》Flowable是一个使用Java编写的轻量级业务流程引擎,Flowable流程引擎可用于部署BPMN2.0流程定义,创建这些流程定义的... 目录1、流程引擎介绍2、创建项目3、画流程图4、开发接口4.1 Java 类梳理4.2 查看流程图4