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

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

using system;

using system.text;

using system.threading;

using system.threading.tasks;

namespace wenli.data.rabbitmq.console

{

using console = system.console;

class program

{

static void main(string[] args)

{

console.title = "wenli.data.rabbitmq.console";

console.writeline("正连接到mq");

try

{

test();

}

catch (exception ex)

{

console.writeline("err:" + ex.message + ex.source + ex.stacktrace);

}

console.read();

}

static void test()

{

var topic = "testtopic";

var cnn = rabbitmqbuilder.get(mqconfig.default).getconnection();

var operation = cnn.getoperation(topic);

console.writeline("正连接到订阅【" + topic + "】");

operation.subscribe();

console.writeline("正在入队");

task.factory.startnew(() =>

{

while (true)

{

operation.enqueue(encoding.utf8.getbytes(datetime.now.tostring("yyyy-mm-dd hh:mm:ss.fff") + " hello!"));

thread.sleep(1);

}

});

console.writeline("正在出队");

task.factory.startnew(() =>

{

while (true)

{

var result = operation.dnqueue();

if (result == null)

{

thread.sleep(1);

}

else

{

console.writeline(encoding.utf8.getstring(result));

}

}

});

console.readline();

console.writeline("正在取消订阅");

operation.unsubscribe();

console.writeline("测试完成");

}

}

}