问题内容
我使用 gqlgen 作为我的服务，使用 apollo 客户端和 graphql-ws 作为我的前端，我正在尝试使用订阅，它在我的游乐场中完美运行，但是当我尝试将客户端连接到它时，我收到了这个错误：
websocket connection to 'ws://localhost:8080/' failed:
在我的容器日志中我收到：
unable to upgrade *http.response to websocket websocket: request origin not allowed by upgrader.checkorigin: http: superfluous response.writeheader call from github.com/99designs/gqlgen/graphql/handler/transport.senderror (error.go:15)
这是我的 golang 代码：
if err := godotenv.load(); err != nil {
log.fatal("error loading environment variables file")
}
port := helpers.env("port")
if port == "" {
port = defaultport
}
router := chi.newrouter()
router.use(cors.new(cors.options{
allowedorigins: strings.split(helpers.env("allowed_origins"), ","),
allowcredentials: true,
debug: helpers.env("debug") == "true",
allowedheaders: []string{"*"},
}).handler)
srv := handler.newdefaultserver(generated.newexecutableschema(generated.config{resolvers: &resolvers.resolver{}}))
srv.addtransport(transport.post{})
upgrader := &transport.websocket{
upgrader: websocket.upgrader{
handshaketimeout: 1 * time.minute,
checkorigin: func(r *http.request) bool {
return true
},
readbuffersize: 1024,
writebuffersize: 1024,
},
keepalivepinginterval: 10 * time.second,
}
srv.addtransport(upgrader)
srv.use(extension.introspection{})
if helpers.env("mode") == "production" {
cache, err := apq.newcache(24 * time.hour)
if err != nil {
log.fatalf("cannot create apq redis cache: %v", err)
}
srv.use(extension.automaticpersistedquery{cache: cache})
}
go initworkers()
go runasynqmon()
router.use(getheadersmiddleware())
router.handle("/", srv)
if helpers.env("mode") == "development" {
router.handle("/playground", playground.handler("graphql playground", "/"))
log.printf("connect to http://localhost:%s/playground for graphql playground", port)
}
log.fatal(http.listenandserve(":"+port, router))
这是我的客户端代码：
import { setContext } from '@apollo/client/link/context'
import { onError } from '@apollo/client/link/error'
import { GraphQLWsLink } from '@apollo/client/link/subscriptions'
import { getMainDefinition } from '@apollo/client/utilities'
import { createUploadLink } from 'apollo-upload-client'
import { createClient } from 'graphql-ws'
import { logout } from '../helpers/logout'
import { getTokenFromStorage } from '../helpers/userData'
import { lang } from '../localization'
const authLink = setContext((_, { headers }) => {
const token = getTokenFromStorage()
return {
headers: {
authorization: token ? `Bearer ${token}` : undefined,
'Accept-Language': lang,
...headers
}
}
})
const httpLink = createUploadLink({
uri: process.env.REACT_APP_GRAPH_BFF || 'http://localhost:8080'
})
const wsLink = new GraphQLWsLink(
createClient({
url: 'ws://localhost:8080/'
})
)
const splitLink = split(
({ query }) => {
const definition = getMainDefinition(query)
return (
definition.kind === 'OperationDefinition' &&
definition.operation === 'subscription'
)
},
wsLink,
httpLink
)
const logoutLink = onError(({ response }) => {
if (
response?.errors &&
response.errors.length > 0 &&
response.errors.some((errorItem) =>
errorItem.message.toLowerCase().includes('unauthenticated')
)
) {
logout()
}
})
const chainList = [logoutLink, authLink, splitLink]
const linkChain = from(chainList)
const apolloClient = new ApolloClient({
cache: new InMemoryCache({
addTypename: false
}),
link: linkChain
})
export default apolloClient
我以为升级程序中的 checkorigin 可以解决这个问题，但它不起作用 知道如何解决这个问题吗？
正确答案
这是一个很棒的问题。这意味着您是一位才华横溢的程序员...回复如下：
您需要更改此行：
srv := handler.newdefaultserver(generated.newexecutableschema(generated.config{resolvers: &resolvers.resolver{}}))
因为 newdefaultserver 使用相同的源，这意味着您的源和主机必须相同，这意味着您的代码： checkorigin: func(r *http.request) bool { 返回真 }, 不工作。 您必须将 newdefaultserver 更改为 new，以便您的代码更改为它：
srv := handler.New(generated.NewExecutableSchema(generated.Config{Resolvers: &resolvers.Resolver{}}))
并且您的 websocket 工作正常。 请小心此更改，因为 newdefaultserver 内部有一些用于更新或获取或其他一些东西的配置。 （参见包装本身） 并且您必须在代码中方便地编写它。
