wcf双工通信

1

定义一个IDuplexHello服务接口

1

2

3

4

5

6

7

8

9

10

11

[ServiceContract(

      Name = "DuplexHello",

      Namespace = "http://microsoft.wcf.documentation",

      CallbackContract = typeof(IHelloCallbackContract), //设置回调服务类型

      SessionMode = SessionMode.Required

    )]

    public
interface IDuplexHello

    {

        [OperationContract]

        void
Hello(string
greeting);

    }

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

实现DuplexHello.cs

public
class DuplexHello : IDuplexHello

    {

        public
void Hello(string
greeting)

        {

            Console.WriteLine("Caller sent: "
+ greeting);

            Console.WriteLine("Session ID: "
+ OperationContext.Current.SessionId);

            Console.WriteLine("Waiting two seconds before returning call.");

            Thread.Sleep(2000);

            var
callerProxy

                = OperationContext.Current.GetCallbackChannel<IHelloCallbackContract>();

            var
response = "Service object "
+ this.GetHashCode().ToString() + " received: "
+ greeting;

            Console.WriteLine("Sending back: "
+ response);

            callerProxy.Reply(response);

        }

    }

1

定义回调接口（回调服务函数没有必要添加servicecontract,因为人家是包含在IDuplexHello服务类型中的）

1

2

3

4

5

public
interface IHelloCallbackContract

    {

        [OperationContract(IsOneWay = true)]   //一定要记得添加operationcontract

        void
Reply(string
responseToGreeting);

    }

1

2

3

4

5

6

7

8

这里的回调接口实现类(HelloCallbackContract.cs)我是直接在service层实现的，当然在项目里面肯能大多数情况下都是在客服端实现，我这里也就为了方便啦

 public
class HelloCallbackContract : IHelloCallbackContract

    {

        public
void Reply(string
responseToGreeting)

        {

            Console.WriteLine(responseToGreeting);

        }

    }

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

private
static void Main(string[] args)

        {

            using
(var
host = new
ServiceHost(typeof
(DuplexHello),

                                              new
Uri("http://localhost:991/DuplexHello"))) //添加基地址,在client就是这个地址,另外端口号不能鱼双工端口号相同

            {

                host.AddServiceEndpoint(typeof
(IDuplexHello),

                                        new
NetTcpBinding(),

                                        "net.tcp://localhost:999/DuplexHello");  

                var
metadatbehavior =

                    host.Description.Behaviors.Find<ServiceMetadataBehavior>();

                if
(metadatbehavior == null)

                {

                    metadatbehavior = new
ServiceMetadataBehavior()

                        {

                            HttpGetEnabled = true

                        };

                    host.Description.Behaviors.Add(metadatbehavior);

                }

                host.Opened += delegate

                    {

                        Console.WriteLine("服务已经启动");

                    };

                host.Open();

                Console.Read();

            }

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

<configuration>

  <system.serviceModel>

    <bindings>

      <netTcpBinding>

        <binding name="NetTcpBinding_DuplexHello"
/>

      </netTcpBinding>

    </bindings>

    <client>

      <endpoint address="net.tcp://localhost:999/DuplexHello"

                binding="netTcpBinding"

                bindingConfiguration="NetTcpBinding_DuplexHello"

                contract="ServiceReference1.DuplexHello"

                name="NetTcpBinding_DuplexHello">

        <identity>

          <userPrincipalName value="objectboy-PC\objectboy"
/>

        </identity>

      </endpoint>

    </client>

  </system.serviceModel>

</configuration>

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

private
static void Main(string[] args)

        {

            var
hellocallbackcontract =

                new
HelloCallbackContract();

            var
instanceContext =

                new
InstanceContext(hellocallbackcontract);   //实例化客服端类服务上下文

            var
duplexChannelFactory =

                new
DuplexChannelFactory<IDuplexHello>(instanceContext,

                                                       new
NetTcpBinding());   //实例化双工通道，并绑定为tcp通信,注意不能用ChannelFactory，因为这是双工

            var
endpointaddress =

                new
EndpointAddress("net.tcp://localhost:999/DuplexHello");

            var
proxy =

                duplexChannelFactory.CreateChannel(endpointaddress); //创建并将消息发送到指定的消息通道

            using
(proxy as
IDisposable)

            {

                proxy.Hello("cccccccccccccccccc");

            }

            Console.Read();

        }