RabbitMQ整合

使用dockers下载带management的版本,该版本是带web界面的,可操作性比较强
aaarticlea/png;base64,iVBORw0KGgoAAAANSUhEUgAAAFoAAAAoCAYAAAB+Qu3IAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAABHSSURBVGhD7Vp5eJXVmf/mGW0dndE+05a2M+ozZQ8JEHZhqrRatR0fGDrtQIvQB9DiqFhkSQJoKSBkT5S9QFjCIlsSgYAVAVdQFEVBUDAgsia5N8u9yb3fcrff/N7zfV+4SS6IHZlnnPLHL2d/z3t+5z3vec93o0VjUfzfQcxByzo7H2uqiziIr/uf4KK8q4X/JaITEZgIlyZaCE1E6ldDdJi4ykT7G/zwN/jgI+z8NVwNaLqhQ2CYxlWDO8cX48v0/XpBiyfEtMyrAsNqTvylwb4J67/+aEa0YV5dy/7rQGJjIdHSYBFieUGm18j+yyE8hp20eZtm8s+VoOXAa0gEm2jTiJAzCxaNN0TXaZnB1kRbCXCN6MvD5o73kRkiIuCVhJAZQ5hkI6IjGmkQoukqxGUo6OyoXyP6S8A1TpMRU4jWbBlRhHUgRtJhVSIaPES8D80yG0mwHzphWI0cGODA5mRfI/ryEI5ChkmCdUSCAYApImcRrVsP4/xTiFQ+JUQHFbmGFUhI8ldCtHtiLtXW4gK2j2Jcn4SQS9y54XkS3RMpZXt8/OmUvKPD5dBCj8shyL4CI2TrYBkNxFa6ibGo8STBV3UrdO8PYHn/EeHaG4Ro8S32YFHKjULs+iAtnY8IiYXZ5hLgwu7rLlIg+URwF2LP0zTeaZN5XGJscgRufXMCdBmj8nLxWGyXfPM5bOOQfiLPJbo17HF8UHCcwNbFbXPz5IHuwDJJJE+93dYANNL/NtI9mOcQCSxCsO4J6A0D0Vh/C/xVGgyvRpI1RGptkGhR1lbaJlfK4tSlLoggSbaJbq6kvUAnjHHJVHWJ4CxKbYzMYcNtE3kXT5JOX2dDyLZ4yi7OZVIfOX12WfS0dbbl2vLklo+vs8stET9GNi+o1nBRDznd9gkXa5XLzUeI1cqcNaDJAvXv000sRqi2Gxou/C3MOg16jYaQR0OYJAuiDloQbSBiWAgT9nOYhFsh9YQU1xKkD7cRcCxLxoXiIDFkItgkuWXTgdtmh0JcgMHLhPkQ5xfYpMiiRXZE9Zf51cYqsuwxF2VJP1uWXeeWHfkKdtlds0C3LMp1N4XtSiYNgHPJRtubH6BOjCjofq3gKcR8ZbA8v0LYfxMCJNLwfAPR+r+BResNk2xBhFBEk/hWRMtRDXALG1gOB7m7IQuNRgABThSQNgfKR+lMuQkKvACCOi0uAXS26dJX9ZG8DXes5I0m0JIcSN7QG+2+SpaBgCFyxAhIEFMZY7czdb6VNNU58i/K5qlz5OpEkOsSBBxI3u2rMy99TM5nml6ST6IlcDA/hj+YTTfRA3XnNQToJoIkUiehoXqCVu0SHU92M6JdvxlkGhTiOVF1GJhVehKTXggQQRtbgpi8RUf6Vh0Z5YaNbSZhJYDU65hCZJTbkLxdtsdO2WZgqoJOBDFtW0BB8gJXdjqRVm4yDXEcwXoZk8Gx6UTa1iDToCPf1cuVL7Jt+UpmeaAJaeVBhXTqZuthjxP50yhj6vZqTN3ayPV+jifKVuOhkp6YuFrD9CUaTntvgemnRdOSTZIqfllch8CSlGVxIa2JVuAR4nEySfqJCPCTnKPoOTeIXy6P4D9WGLhzXhDJuWF0zAU65hN5QGeikwMpCzo4ZWlLYt9OOaxj//bMd2bagWl7trWPk5HkpG57p7g5OjFtR8gYae/strnt0p+pyBeZ7ZiXNlc3V6/O1EPmEf1FjtQpPaSOZXdONQ/z3XJD6JodQafsA/jeM4/h5tkaBhIjMjXs+fg78JHQAGEQejVTWrnpwGJZSG/lOiTKELItiTZCOj6JAQ8s/BBLvMC2AxGseuUUtp4H+meeU0qIoqJYV6YpuRF0ybGQkhdAcn6ACwkjJdtWsls2kDzHXnw7LjSZ/buw7occ+y8io4Djc8Lsa6EL5QjJbdlPZHdmW5f8GLoVOkTLXHkxpOZGnc2Nqo3swv4iswOJaV9goUNhDB05NpntQnY7trWbE0EqU6VPFvUW0pmKEXTKjyCpMIJk5jtwXFvKTGH+rkzgR5l+pGYuxu3P3IaOCzW8dOpbWLhJw6GqtmgkkUESqjtku1YddhBiW2KiackW4RL9+PrTWMtLdtCCMO7MP45dHmDKkrMkOaaITiK65voweKUfg5dUYdTaWoxYXo3B82vwSHEADy8P4b68ILrnGrhjcQ2GFvvxu5W1GLOihiSE0Ts3gKErdDy49DQeX1mJ36wIoGdOPZKyDQyY34gHV/vw8JpqjChuVBvU/tkY7lsWwKOrPRhbVIlRKy9g4AI/yTTx02U6RhZX4RGO+flzfkX0L4r8GLq0GqNYN7rYiyFz6zFmZQNGrPBh4HM0iswINziI/1wTo06VeGStD33zfEihsQwqBh5bBGSsocsouh8DsjQMWKPhRGMb7Nih4VRVGzSQTPHVuuCCDYMIEZFKgvVXRPS92UfQK9ODAZz8N0VH8UY98NvcaiRzEWKJ7WhZfQq92B0E/szI5/eb/NhPl3OEp+C/NgFlnwFrPwL65dRizSfAzDeAR18Ayn3AU7uA+7Mr8AZDqHL2e2gnsJch6sRttLwCP+gWMWk7N5t4KQqM3woMX/E5NtcC40rDWMb2Cuo4if77jrxKvFHJOSl73lHg+bPA4IVB7DwHvMto4enyKMqpu/SZ/howl7psOiKnw4+MnTG8ykfduC3A/GPEAWAEjYkuGvtOct7SkdjmvRtT12no+/w3ccx/O7a+rOGI5wfKil0ov0yIJUcIiTgShnfiNiS0CZFoQ4jm4u7KPqVcw4PlVJ7kbeQiRmafsf2uHDEe476FF/C2H1j0CvDzOZ+i7DTw6pt+/GuWD4v2c6F1JKiIG/EpMGbJ53honQ9ldEFbWP73OW/jHZL7+ILjaFfQiC1c2PLDwI+XA9uPhDGs8AhGrzmDnVz0Qm7SLrbnvBZD75wqDOHFRt4w64UqLDnBzXjHw9NzAj/LO4i97D9zSwz7SfTKfXSBsz9F1rvAOzyd9xSewbDiSpzg26P//Frs4bqW7q7GffmfYeS6YzhGo5m+6mO8yk0sWLcTfXK+gzn7NOw6quH25+gyan6IRc9reNdzazOiDboJk7BoxWEB80J4K6Ldl1SYli2/jnwil2FWBf0W/a/4xkIdRe8Ab9IaOufqSOaRS87T0TfnBN4SC10D/CyzFss/Bl7YraN/Vg3y9kawnxb4a/rfDRy3i4t6mezsosVtYXlI1uvqNIxe6KWPjeFFblIRT0C3PANl3IjX2b/kuIE3KX/pm8BJkpP9qvjqEJJWRXCKxpBbdgo7uNEH2baZxG7jJn7Ih9szZQHsu0ALpwXfM9uLp7np2+WOyarEsFW1OMHNuG9RNQ4zfY86bSRKqKuHMvM2VGAH1z/5T7N4+X8X017T8PJHGjrM13DYIfqA5zY00GKFZJNQ/plQBDskJyBaYDIwNxCVlI+VEwzvfjvvEMas56VGC76dZOfsBT6gnx5H61hLpUu5kNxXLLzFhWaQ6B/zolxewQXt0tErrwE5b8fwNi16Go/0eR7PBxfVo/+zXnXst3BDBmUdAKMsjPhTLbpmxbCNLmQJj/RwuouT3IxBBecwoOA4Skn0Ys79Ed1TJi27XWEYfdYBZ4To7eewpRFY8WIjBnLj++TWYvj6MIY8V439JG8hN+iuZ6ow5S17E/plVeNXK/w4Tpdyd7EHHzJ9hhdR9+xG3LHAh7FrQxi+8Ah2kugnM4ci5Y/XYwaJfv2Yhk5zNRz3tccyEv1B1T+r57YimRCSIwKH4Eu4Dr7ISHBYES35MCp4pEcVf4YXeTynbKzHvZn7sYt+bjrj6a6MLgYUGuiXXYf7CyoU0U+vDuGe7NNYRD+3bQ/bchuQz8Xto5U8sQE4Tct9dPEnGF1UgY9ocQdpvcPy3kU5SRqxyItURgfiq5fSPQ37M3CC40YWfoCp3M2T3PS9B4EZ2z0o40YPZX0uN5vTYtomL4Y9H8MB9h805wgyNtbhPZI0fEkUe2kIC7gx92ZW4ym6kB0k+ke5dfg1L8QKEty9oA4rON+eU3LqjmDmy35soPwhy06qe+HJOfei63QNs0j0K4c1dJsnLuM2LCXRR8/eYMfPtF6xYkWsQ3IT0UQLouUJSrdB9xERovkEl8XdnfMBBm8wUUpS1hDjt0l4V6dcicSjSfTTvZ8NYj6t8GH6VXEXk2hBs3ixpOZZGMddmvshXVCBgXzWF4troD9dTBe0ikQ9UPgZGKrj3+ZbdBdAFjdmMo96l7kBLOSltIrEF9OFLCFJRbt51LMO4Q+8NLefoe+lv75AY3hsFSOVAhNTWL+W8jcTY2mxA+YYmPseyeL90p/WOnoHMIfl3rT6+5eGsYIG0Y3r6J99FvO5ies5T9Fx4KcLa9BvbiXyqecv5/RF0h81/K7sOhTu+Tu0nalh5ks3YOuhG1FR920E+RoUooXQGFPQgqPyInRehWj9UUkiDvmYwstQvjXwicvNxwM5x9CTMWbP/Ch6kNQeBTEiilTGqT2Z9iiIoDvjz1Qe5V4M13rlhdjXQg/60K6s70Z0ZUwt1iqxttSlcAOkvQ/9cB+Gfj2Z784Fy9hevFy7EinPRtGLoV8P9ulOud0ZD4vfXkW3VEgX8pPZ5zGWxIt/HZJzXsnvzpCzD+fqRfmp1DmVMnvmcyzzKdQzpSCMLoVRpiFVFmPpznGpHNc1xyB47zCe78x5unDu1OyDSJrRBl1maEgm2YIk5nv8QcOdGbTs6u/DL0Q7lhsjQMjTW31YIvEWQ7xWRDeGGhFgxBEyI4iFLZzj8Z6+4TjSN/swuaQGk0trkVZah/QSX1M6ubQek1R9FftcYF8PMjZ7kVZShakcl7apnm0NeHKjj6hiXx8msH4Cbx3pJ0gnJrM8XuQwdsso8XM8n72lNQppJfWcy49JmzzILjkCL6MB8gs/rTl70+d4ujSAyZsaVHt6GU9UiZeQ1IOJHDuRMiaWVXNOD3VpVDo8uZntTMeXGpjES3MC5Y8vCSCdciZTh0lcR9rm1zB+rYYJjJ3l2T1xlYZJRNpyDTOKNJyrvdEO5RhhKGsWCNkkOSbw/D1mj29BtHw6dL8/W7wIxV83cCFekl1NVNGNKDhlD/MC+R5STX/oISRVZaKKea/kpb+UmVaKHCe94NSpdqlnWeqUbLfeKTf1IWqpU6MlX/MkSrJQxzrpL20KHFPZAq7ukle6xEHp4UDa1dxMZb5aqw61DaPgrW+L6tqbUVVzC/M3oabuH1Bfe736cqd8srgOl2gHUh/ig2bmuBZEN4d8hmxdF182Q+yTAPKrg+6kzdtITFxZ+gji6+xvLX85muQQrXRQn0ITj0sECXXDOm/I+nT6247KDytfTJ8bc/yve+m5F5+yalq3IpoIVX0fsyZclugvQtwCWuD/E9FRk7dUYB4J7qJ8riKaJMsF57oH91Oo7SpskpX7EPKrv4uZk6+YaFFQEF9OrJxA3E/QgXxUNxIssHmf5m1fBeLlJ2q/UoTpOmC8jkhtf0WyfCCS78xCthArZMd/d1ZRhkOyTXQbzJp0BURLW8t2u+7SZMcvsjmRF8d8LYjm2HCIgb9xlo+S4Xxe36zIFssW1+ESLSTHEy1W7UYf0ervYfZEEi2EXfz9TIh08zaat7esS6CcgArKQm3E92s+xu0TX9cSpmrXHdjH2UXLvs3QNH+CtlawZbcCx4bo7mDJj7HzEKzspl6AEmU0uQqH3Hi49QLL0wbT0kh0c+FCdHz5q4C7QYnarhDygSuOaPVN5kv628tC/bCcmGx5U6gfCsPvk7SxML03IiQWLGQ7aEm2eoI7CHjbYPyUVkRfQ0vIyQ1LwG4GEarbimDVL9QHfkW0XIxEPNFCrvt7oTzNG7y3IWPiTdeI/iII0fKreIynHRKBWFsQq++HUOW3EK26/rJEW0TAcyum/f6b14i+Esi/NcgniajpI9GHgUgOw7veiF64mWR/Q118EoWoS7EF0Ybn25idHu86rujS+GuE3AXyfyLyWq5HxOIDJrwf0NOgn+8Ds/KfElqzRCbiy03vdaiuaGsTLf8Mo/4lqtUk12BDggT3P6qkLBdnAy/k3TCCY2DVXWeHdPFkS+qQbdRo+G/u209yjioQGQAAAABJRU5ErkJggg==" alt="" />

启动

 
第二个-p是web界面的访问地址
 
客户端进行访问:

账号密码均是guest

看图进行设置:

1、添加exchange(交换器):

全部添加之后

2、添加队列

3、绑定

........

4、发送消息

........

再队列中查看消息

工程中进行整合

新建工程:

1、自动配置的类

1.1、---有自动配置了连接工厂

1.2、---基本的 配置类

封装了RabbitMq的所有配置

自动配置的配置类

1.3、---RabbitTemplate 给RabbitMq发送和接受消息

1.4---AmqpAdmin  系统管理功能组件

1.5---aaarticlea/png;base64,iVBORw0KGgoAAAANSUhEUgAAAIMAAAAcCAYAAABCrQzwAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAANvSURBVGhD7ZlNaxNBGID7c/RkjWAtWKTGatuowTSCjQQpjdBDSyoohuIhBNTUiz2kIPUDPYT1INWLEgyI/+x13tmZ2ZnZmU3SXUuTvIeH7L7zuTPPfFhnrl5bBIJASAZCQTIQiplCoQAEgcycu3gebDBhZWmemDJIBkJBMhAKkoFQkAyEgmQgFNnJsLoIt7Z2YOnFG7jx8h0HnzGGac4yxJkiExmWKxXIs8nP7390w9Iwj6vsdFODw/4B1J1pp09qGbgIbYcANiyPX4gitII+9PtdaK270nHQWHqwB9VY2jgzQTIss+0/cUewwR3CeWSEMgRBF4JmMZZebXaZKCRDFtS2HsNaacWI4TvGU8mA9wFjstsfYG5zF2YLZcjdeQC5taqZzuB3iFhdoQyHzT0IYoODaWzHaB6QDBkgJ14Kob+nkgEviPpEX9l8ApfKVbj+yr9bYJl4XUKG7Xmod9gOoe8O20IC+avKiKNDoJdROwknGmxffGUdJZTxsB+yLrMdl5T+fpi48lkyJPRj5G9KQApQeVg2xEglg31EXLhZhIVG24jFYGXidUUy8MlXH2XF1STgIOr3Cy0fH1DHoPjiWLajTa7RfjiB0aSE7QzVD/4uCeuJi6LLkNCPkb9pMFIE/JWxjGW4CwvPXxuxGINkEM984HQB7Ge1GiKi1Ybv9mXUFw9xrjC9TcnQ/fCUMdBlCHGv9JN9k4//sjPYx8TljR3IldzHxNH333Dc+wtH33456rJWlBi8ln5k2JPgHFydsM74QFlxsTWrdvTV5mpn5H4wvPk0GZL6oRjym4wyJlIEKYD+nvEF8j3MbdRhdrUEs7fvs/vDIx6/9/YLF6Hx+Zj/xuuyZFDGa4NhDGiYrm/H9U40qC0V1+r1xa2JClembNduRwz6kP0I1OTY+Wrs7iF3MZE/qR+jfpOow4UugkQKkUqGUf5piRJg3uFkEIPRqUV57NXFBxuFCTEnJIrrdbjjYoJFPGCTaaxIox02ufYF0tcPHtdWqpFPl00+J/djtG86GalkQIb5o1Pw8w+XQPL1R89Z11jg3fLHn9QyIIP+HC0leNZ4qp5d9Zw9cLVqu4TY7mMXxAkhExk4Cf9RJQXY3d0eMxkY1jEwqSIg2cmQAB4LUgJkrI+JCeZUZCDGA68M+U89YsogGQhBD/4B51POnSd5jpgAAAAASUVORK5CYII=" alt="" />消息

需要将消息序列化成数组

2、单波

2.1、发送消息
@Autowired
RabbitTemplate rabbitTemplate; //单播(点对点)
@Test
public void contextLoads() {
//message需要自己定义,定义消息体和消息头
//rabbitTemplate.send(exchage,routKey,message); //默认当成消息体,只需要将传入要发送的对象,自动序列化发送给rabbitmq
//rabbitTemplate.convertAndSend(xchage,routKey,message); Map<String,Object> map = new HashMap<>();
map.put("msg","这是IDEA整合的测试"); //对象默认序列化以后发送
rabbitTemplate.convertAndSend("exchange.direct",
"atguigu.news",map);
}
aaarticlea/png;base64,iVBORw0KGgoAAAANSUhEUgAAAIMAAAAcCAYAAABCrQzwAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAANvSURBVGhD7ZlNaxNBGID7c/RkjWAtWKTGatuowTSCjQQpjdBDSyoohuIhBNTUiz2kIPUDPYT1INWLEgyI/+x13tmZ2ZnZmU3SXUuTvIeH7L7zuTPPfFhnrl5bBIJASAZCQTIQiplCoQAEgcycu3gebDBhZWmemDJIBkJBMhAKkoFQkAyEgmQgFNnJsLoIt7Z2YOnFG7jx8h0HnzGGac4yxJkiExmWKxXIs8nP7390w9Iwj6vsdFODw/4B1J1pp09qGbgIbYcANiyPX4gitII+9PtdaK270nHQWHqwB9VY2jgzQTIss+0/cUewwR3CeWSEMgRBF4JmMZZebXaZKCRDFtS2HsNaacWI4TvGU8mA9wFjstsfYG5zF2YLZcjdeQC5taqZzuB3iFhdoQyHzT0IYoODaWzHaB6QDBkgJ14Kob+nkgEviPpEX9l8ApfKVbj+yr9bYJl4XUKG7Xmod9gOoe8O20IC+avKiKNDoJdROwknGmxffGUdJZTxsB+yLrMdl5T+fpi48lkyJPRj5G9KQApQeVg2xEglg31EXLhZhIVG24jFYGXidUUy8MlXH2XF1STgIOr3Cy0fH1DHoPjiWLajTa7RfjiB0aSE7QzVD/4uCeuJi6LLkNCPkb9pMFIE/JWxjGW4CwvPXxuxGINkEM984HQB7Ge1GiKi1Ybv9mXUFw9xrjC9TcnQ/fCUMdBlCHGv9JN9k4//sjPYx8TljR3IldzHxNH333Dc+wtH33456rJWlBi8ln5k2JPgHFydsM74QFlxsTWrdvTV5mpn5H4wvPk0GZL6oRjym4wyJlIEKYD+nvEF8j3MbdRhdrUEs7fvs/vDIx6/9/YLF6Hx+Zj/xuuyZFDGa4NhDGiYrm/H9U40qC0V1+r1xa2JClembNduRwz6kP0I1OTY+Wrs7iF3MZE/qR+jfpOow4UugkQKkUqGUf5piRJg3uFkEIPRqUV57NXFBxuFCTEnJIrrdbjjYoJFPGCTaaxIox02ufYF0tcPHtdWqpFPl00+J/djtG86GalkQIb5o1Pw8w+XQPL1R89Z11jg3fLHn9QyIIP+HC0leNZ4qp5d9Zw9cLVqu4TY7mMXxAkhExk4Cf9RJQXY3d0eMxkY1jEwqSIg2cmQAB4LUgJkrI+JCeZUZCDGA68M+U89YsogGQhBD/4B51POnSd5jpgAAAAASUVORK5CYII=" alt="" />用于rabbitTemplate.send(exchage,routKey,message);
运行在web界面进行查看结果!!!

此时这个队列已经接收到消息

2.2、接受消息

接受之后消息信道的消息就会消失!!!

2.3、如何以json的方式进行显示

可以自己写一个自定义的

新建一个配置类

@Configuration
public class MyAMQPConfig {
@Bean
public MessageConverter messageConverter(){
return new Jackson2JsonMessageConverter();
}
}
再次进行测试
此时过去的就是json数据类型

此时也可以进行消息的接受消息
也可以进行反序列化

测试对象:

public class Book {
private String name;
private int price;
public Book() {
}
public Book(String name, int price) {
this.name = name;
this.price = price;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getPrice() {
return price;
}
public void setPrice(int price) {
this.price = price;
}
}

接收到信息

此时是可以拿到数据以及类型,此时可以做强转!!!!

3.广播
//广播
@Test
public void sengMsg(){
rabbitTemplate.convertAndSend("exchange.fanout","",new Book("三国",));
}
此时的routKey可以不写,因为是广播
 
此时查看队列

所有的信道都会收到消息!!!

最新文章

  1. Windows Phone 七、XML序列化
  2. [转载]AxureRP常用快捷键
  3. Python QRCODE
  4. 1021: A除以B
  5. OpenJudge/Poj 1753 Flip Game
  6. 【解决】小米M1刷机教程(卡刷)
  7. 一、Linux启动过程详解
  8. 1692: [Usaco2007 Dec]队列变换(BZOJ1640强化版)
  9. 【Beta】阶段 第三次Daily Scrum Meeting
  10. echarts使用总结
  11. meta 刷新
  12. Python 3.6 中文手册——前言
  13. Vue+Element的动态表单,动态表格(后端发送配置,前端动态生成)
  14. vi命令保存
  15. centos卸载mysql
  16. [No0000158]思维模型1-20
  17. 4698: Sdoi2008 Sandy的卡片
  18. IntelliJ IDEA 快捷键积累
  19. APP-11-视觉技术-通用文字识别
  20. icpc 2017北京 J题 Pangu and Stones 区间DP

热门文章

  1. 微信小程序button选中改样式-实现单选/多选
  2. Oracle数据库web维护管理及监控
  3. 第二章.JSP/Servlet及相关技术详解
  4. Java 学习笔记(1)——java基础语法
  5. 【零基础学习FreeRTOS嵌入式系统】之一:FreeRTOS环境搭建
  6. 新版qq canvas 动态背景
  7. MySQL数据库更改默认引擎为Innodb【配置】
  8. 几个 h5页面效果和 自动 app 生成网站 微页
  9. ORACLE数据仓库学习记录
  10. C# winform 打印事例