1、编写一个类A继承Thread，重写run方法，里面使用socket读取数据，发送到消息队列；2、开启多个A的线程并启动，运行的同一个run方法，但是连接的不同socket(ip和端口用A的构造函数传入),消息队列的交换器和路由key都不同；3、消息队列读取相应的消息解析并插入数据到同一张表。这样会存在多线程安全问题吗？
要看你有没有共享变量，也就是多个线程同时去写一个变量，如果有，就会有线程安全问题，只读的话不存在线程安全的问题；